相关疑难解决方法(0)

我想Source在它上面创建一个和后来的推送元素,如:

val src = ... // create the Source here
// and then, do something like this
pushElement(x1, src)
pushElement(x2, src)

建议的方法是什么？

谢谢!

我正在使用我无法控制的java库中的数据发布者.发布商库使用典型的回调设置; 在库代码中的某个地方(库是java,但我将在scala中描述terseness):

type DataType = ???

trait DataConsumer {
  def onData(data : DataType) : Unit
}

库的用户需要编写一个实现该onData方法的类并将其传递给a DataProducer,库代码如下所示:

class DataProducer(consumer : DataConsumer) {...}

它DataProducer有自己的内部线程我无法控制,并伴随数据缓冲区,即onData每当有另一个DataType对象要消耗时调用.

所以,我的问题是:如何编写一个将原始库模式转换/转换为akka流源对象的图层？

先感谢您.