После того, как вы .establishConnection()
, вставьте .doOnNext( connection -> savedConnection = connection)
и используйте savedConnection
для будущих операций.
Не забудьте .dispose()
, когда закончите, чтобы разорвать соединение (а также установить savedConnection = null
).