Subscriber < T > function ( final Subscriber < ? super T > arg0 ) { return new Subscriber < T > ( arg0 ) { @ Override public void onCompleted ( ) { arg0 . onCompleted ( ) ; } @ Override public void onError ( Throwable arg1 ) { arg0 . onError ( arg1 ) ; } @ Override public void onNext ( T arg1 ) { arg0 . onNext ( arg1 ) ; } } ; }
returns a new subscriber that passes all events tosubscriber , has backpressure controlled by subscriber and uses the subscription list of subscriber when subscriber #add rx.subscription iscalled . concode_field_sep PlaceHolder placeHolder concode_field_sep Subscriber<T> create concode_elem_sep Subscriber<T> create concode_elem_sep Subscriber<T> create concode_elem_sep Subscriber<T> from concode_elem_sep Subscriber<T> empty