public class ConvertingPublisher<R> extends Object implements org.reactivestreams.Publisher<R>
Exchange
s into the given type.Constructor and Description |
---|
ConvertingPublisher(org.reactivestreams.Publisher<org.apache.camel.Exchange> delegate,
Class<R> type) |
Modifier and Type | Method and Description |
---|---|
void |
subscribe(org.reactivestreams.Subscriber<? super R> subscriber) |
Apache Camel