code: public void bridge(final ChannelFuture future, Subscriber<?> subscriber) {
          future.addListener(this);
          subscriber.add(Subscriptions.create(new Action0() {
              @Override
              public void call() {
                  future.removeListener(SubscriberToChannelFutureBridge.this);
              }
          }));
      }
docs: Bridges the passed subscriber and future, which means the following:
  
  <ul>
  <li>Add this listener to the passed future.</li>
  <li>Add a callback to the subscriber, such that on unsubscribe this listener is removed from the future.</li>
  </ul>
  
  @param future Future to bridge.
  @param subscriber Subscriber to connect to the future.