code: public Closeable onSubscribeChannelEvent(final Consumer<BitfinexStreamSymbol> listener) {
          subscribeChannelConsumers.offer(listener);
          return () -> subscribeChannelConsumers.remove(listener);
      }
docs: registers listener for subscribe events
  @param listener of event
  @return hook of this listener