org.apache.camel.rx.support
Class EndpointSubscription<T>
java.lang.Object
org.apache.camel.rx.support.EndpointSubscription<T>
- All Implemented Interfaces:
- rx.Subscription
public class EndpointSubscription<T>
- extends Object
- implements rx.Subscription
An RX Subscription
on a Camel Endpoint
Constructor Summary |
EndpointSubscription(org.apache.camel.Endpoint endpoint,
rx.Observer<? super T> observer,
rx.util.functions.Func1<org.apache.camel.Exchange,T> func)
|
EndpointSubscription
public EndpointSubscription(org.apache.camel.Endpoint endpoint,
rx.Observer<? super T> observer,
rx.util.functions.Func1<org.apache.camel.Exchange,T> func)
toString
public String toString()
- Overrides:
toString
in class Object
unsubscribe
public void unsubscribe()
- Specified by:
unsubscribe
in interface rx.Subscription
isUnsubscribed
public boolean isUnsubscribed()
- Specified by:
isUnsubscribed
in interface rx.Subscription
getEndpoint
public org.apache.camel.Endpoint getEndpoint()
getObserver
public rx.Observer<? super T> getObserver()
Apache Camel