我正在使用我无法控制的
java库中的数据发布者.发布商库使用典型的回调设置;在库代码中的某个地方(库是java,但我将在scala中描述terseness)：
type DataType = ???
trait DataConsumer {
def onData(data : DataType) : Unit
}
库的用户需要编写一个实现onData方法的类并将其传递给DataProducer,库代码如下所示：
class DataProducer(consumer : DataConsumer) {...}
DataProducer有自己无法控制的内部线程,以及随附的数据缓冲区,只要有另一个DataType对象要使用它就调用onData.
所以,我的问题是：如何编写一个将原始库模式转换/转换为akka流Source对象的图层？
先感谢您.
解决方法
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
