Package org.apache.camel.rx.support

Class Summary

EndpointObservable<T>	An Observable Camel Endpoint
EndpointSubscribeFunc<T>
EndpointSubscription<T>	An RX Subscription on a Camel Endpoint
ExchangeToBodyFunc1<T>	A simple Func1 to convert an Exchange to the given type using the IN Message's body
ExchangeToMessageFunc1	A simple Func1 to convert an Exchange to its IN Message
ObservableProcessor<T>	A base class for implementing a Processor which provides access to an Observable so that the messages can be processed using the RX Java API
ObserverSender<T>	An Observer which sends events to a given Endpoint
ProcessorToObserver<T>	A Processor which invokes an underling Observer as messages arrive using the given function to convert the Exchange to the required object