code: public static void addReactiveBridge(Channel ch, OnSetup opsFactory, ConnectionObserver listener) {
  		ch.pipeline()
  		  .addLast(NettyPipeline.ReactiveBridge, new ChannelOperationsHandler(opsFactory, listener));
  	}
docs: Add {@link NettyPipeline#ReactiveBridge} handler at the end of {@link Channel}
  pipeline. The bridge will buffer outgoing write and pass along incoming read to
  the current {@link ChannelOperations#get(Channel)}.
  
  @param ch the channel to bridge
  @param opsFactory the operations factory to invoke on channel active
  @param listener the listener to forward connection events to