rx-java - サブスクライブをオブザーバブルとして作成するには?

Question

私は RxScala/Java を使用して Observable を構築し、ループでソケット接続を発行します。結果は、すべての接続がイベントとして生成されます。このように、

val server = new ServerEntrance("localhost", 10002)
val socket: Observable[ConnectedSocket] = server.listen

その後、接続が読み取りを開始できるようになります。scoket接続イベントをサブスクライブし、新しい Observable として作成する必要があります。,return
ConnectedSocketを使用して、Observable を接続とし​​て作成することができます。受信した情報でイベントを発行します。このステートメントを return にしたいです。どのように構築しますか?stratReadingObservable[CompletedProto]Observable[CompletedProto]

socket.subscribe(l => l.startReading)

詳細情報が必要な場合は、更新します。