public static void setBackPressureListener ( boolean passthrough , BackPressureHandler backpressureHandler , ChannelHandlerContext inContext ) { if ( backpressureHandler != null ) { if ( inContext != null && passthrough ) { backpressureHandler . getBackPressureObservable ( ) . setListener ( new PassthroughBackPressureListener ( inContext ) ) ; } else { backpressureHandler . getBackPressureObservable ( ) . setListener ( new DefaultBackPressureListener ( ) ) ; } } }
Sets the backPressure listener the to the Observable of the handler .