rx-java - 如何将订阅作为 Observable？

Question

我使用 RxScala/Java 构造一个 Observable 来发出带有循环的套接字连接，结果是每个连接都作为一个事件。像这样，

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

之后，连接就可以开始阅读了。我需要订阅scoket连接事件并将其作为一个新的 Observable。
ConnectedSocket可以使用stratReading，返回Observable[CompletedProto]，创建一个 Observable 作为连接。它发出带有接收信息的事件。我想让这个语句返回Observable[CompletedProto]。如何构造它？

socket.subscribe(l => l.startReading)

如果需要详细信息，我真的愿意更新它。