私が管理していない Java ライブラリのデータ パブリッシャーを使用しています。パブリッシャー ライブラリは、一般的なコールバック セットアップを使用します。ライブラリコードのどこかに（ライブラリはJavaですが、簡潔にするためにscalaで説明します）：
type DataType = ???
trait DataConsumer {
def onData(data : DataType) : Unit
}
ライブラリのユーザーは、メソッドを実装するクラスを作成し、onDataそれを に渡す必要がDataProducerあります。ライブラリ コードは次のようになります。
class DataProducer(consumer : DataConsumer) {...}
にDataProducerは、制御できない独自の内部スレッドと、消費するonData別のオブジェクトがあるたびに呼び出される付随するデータ バッファーがあります。DataType
だから、私の質問は: 元のライブラリ パターンを akka ストリームのSourceオブジェクトに変換/変換するレイヤーをどのように作成すればよいですか?
前もって感謝します。