static < T > Subscriber < T > wrap ( Subscriber < T > downstream , List < RunnableInstrumenter > instrumentations ) { if ( downstream instanceof FlowableSubscriber ) { return new RxInstrumentedFlowableSubscriber <> ( downstream , instrumentations ) ; } return new RxInstrumentedSubscriber <> ( downstream , instrumentations ) ; }
Wrap a subscriber .