public Closeable onConnectionStateChange ( final Consumer < BitfinexConnectionStateEnum > listener ) { connectionStateConsumers . offer ( listener ) ; return ( ) -> connectionStateConsumers . remove ( listener ) ; }
registers listener for notifications on connection state