org.apache.camel.rx.support
Class EndpointObservable<T>

java.lang.Object
  rx.Observable<T>
      org.apache.camel.rx.support.EndpointObservable<T>

public class EndpointObservable<T>
extends rx.Observable<T>

An Observable Camel Endpoint

Nested Class Summary

Nested classes/interfaces inherited from class rx.Observable

rx.Observable.OnSubscribe<T>, rx.Observable.OnSubscribeFunc<T>, rx.Observable.Operator<R,T>

Constructor Summary

EndpointObservable(org.apache.camel.Endpoint endpoint, rx.Observable.OnSubscribe<T> func)

Method Summary

String

toString()

Methods inherited from class rx.Observable

aggregate, aggregate, all, amb, amb, amb, amb, amb, amb, amb, amb, amb, and, asObservable, average, averageDouble, averageDouble, averageFloat, averageFloat, averageInteger, averageInteger, averageLong, averageLong, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cast, collect, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concat, concat, concat, concat, concat, concatMap, contains, count, create, create, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinctUntilChanged, distinctUntilChanged, doOnCompleted, doOnEach, doOnEach, doOnError, doOnNext, doOnTerminate, elementAt, elementAtOrDefault, empty, empty, error, error, exists, filter, finallyDo, first, first, firstOrDefault, firstOrDefault, flatMap, from, from, from, from, from, from, from, from, from, from, from, from, from, from, from, from, from, groupBy, groupByUntil, groupByUntil, groupJoin, ignoreElements, interval, interval, isEmpty, join, just, just, last, last, lastOrDefault, lastOrDefault, lift, longCount, map, mapMany, materialize, max, max, maxBy, maxBy, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeMap, mergeMap, mergeMap, mergeMapIterable, mergeMapIterable, min, min, minBy, minBy, multicast, multicast, nest, never, observeOn, ofType, onErrorFlatMap, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onExceptionResumeNext, parallel, parallel, parallelMerge, parallelMerge, publish, publish, publish, publish, publishLast, publishLast, range, range, reduce, reduce, repeat, repeat, repeat, repeat, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, sample, sample, sample, scan, scan, sequenceEqual, sequenceEqual, serialize, single, single, singleOrDefault, singleOrDefault, skip, skip, skip, skipLast, skipLast, skipLast, skipUntil, skipWhile, skipWhileWithIndex, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, sumDouble, sumDouble, sumFloat, sumFloat, sumInteger, sumInteger, sumLong, sumLong, switchDo, switchLatest, switchMap, switchOnNext, synchronize, synchronize, synchronize, take, take, take, takeFirst, takeFirst, takeLast, takeLast, takeLast, takeLast, takeLast, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeLastBuffer, takeUntil, takeWhile, takeWhileWithIndex, then, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timer, timer, timestamp, timestamp, toBlockingObservable, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toSortedList, toSortedList, unsubscribeOn, using, when, when, when, when, when, when, when, when, when, when, when, where, window, window, window, window, window, window, window, window, window, window, window, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

EndpointObservable

public EndpointObservable(org.apache.camel.Endpoint endpoint,
                          rx.Observable.OnSubscribe<T> func)

Method Detail

toString

public String toString()

Overrides:

toString in class Object