ReconnectingObservable

constructor(reconnectingRPCConnection: ReconnectingCordaRPCOps.ReconnectingRPCConnection, initialDataFeed: DataFeed<*, T>, createDataFeed: () -> DataFeed<*, T>)