public Observable < Void > ignoreInput ( ) { return getInput ( ) . map ( new Func1 < R , Void > ( ) { @ Override public Void call ( R r ) { ReferenceCountUtil . release ( r ) ; return null ; } } ) . ignoreElements ( ) ; }
Ignores all input on this connection .