code: public Observable<Void> ignoreInput() {
          return getInput().map(new Func1<R, Void>() {
              @Override
              public Void call(R r) {
                  ReferenceCountUtil.release(r);
                  return null;
              }
          }).ignoreElements();
      }
docs: Ignores all input on this connection.
  
  Unless, {@link ChannelOption#AUTO_READ} is set to {@code true}, the content will only be read from the
  underneath channel, if there is a subscriber to the input. So, upon recieving this connection, either one should
  call this method or eventually subscribe to the stream returned by {@link #getInput()}
  
  @return An {@link Observable}, subscription to which will discard the input. This {@code Observable} will
  error/complete when the input errors/completes and unsubscription from here will unsubscribe from the content.