returns a newly created observable given a function which convertsthe exchange from the camel consumer to the required type concode_field_sep CamelContext camelContext concode_elem_sep ExecutorService workerPool concode_field_sep Endpoint endpoint concode_elem_sep void sendTo concode_elem_sep void sendTo concode_elem_sep Observable<Message> toObservable concode_elem_sep Observable<T> toObservable concode_elem_sep Observable<Message> toObservable concode_elem_sep Observable<T> toObservable concode_elem_sep Observable<Exchange> from concode_elem_sep Observable<Exchange> from concode_elem_sep CamelOperator to concode_elem_sep CamelOperator to concode_elem_sep CamelContext getCamelContext
Observable < T > function ( final Endpoint arg0 , final Func1 < Exchange , T > arg1 ) { Observable . OnSubscribe < T > loc0 = new EndpointSubscribeFunc < T > ( workerPool , arg0 , arg1 ) ; return new EndpointObservable < T > ( arg0 , loc0 ) ; }