java如何在rxJava中不断尝试直到成功

Question

我想继续尝试建立TCP连接，并且在成功时使用该连接做一些事情

假设这是我的界面：

public interface ConnectionFactory {

    rx.Observable<Socket> createConnection(String host, int port);

}

我想这样使用它：

ConnectionFactory factory = new ConnectionFactoryImpl();

rx.Observable<Socket> rxSocket = factory.createConnection("abc.mycomp.com", 9999);

rxSocket.subscribe(...);

我的问题是——如何实现ConnectionFactory。创建（字符串，int）看起来像什么？不是在寻找一个有效的代码，但指针会有所帮助。rxJava 1中是否有带重试功能的轮询机制。x

它必须继续尝试每10秒连接一次，直到成功，然后再呼叫用户。onNext（插座）。可能会抑制IOException/任何其他连接异常