create a new org.glassfish.jersey.client.rx.rxwebtarget reactive client target instance initialized with givenjax-rs client web target instance and parametrized with invoker based on the rx.observable observable from rxjava.reactive requests , invoked using org.glassfish.jersey.client.rx.rxinvocationbuilder #rx rx ... , operate on a rx.scheduler initialized with provided java.util.concurrent.executorservice executor service . concode_field_sep PlaceHolder placeHolder concode_field_sep RxClient<RxObservableInvoker> newClient concode_elem_sep RxClient<RxObservableInvoker> newClient
RxWebTarget < RxObservableInvoker > function ( final WebTarget arg0 , final ExecutorService arg1 ) { return Rx . from ( arg0 , RxObservableInvoker . class , arg1 ) ; }