Switch to reactor snapshots and make use of API change
Add ListenableFuture to TcpOperations connect methods