com.diffplug.common.rx

Interface IObservable<T>

All Superinterfaces:

ObservableSource<T>

All Known Subinterfaces:

RxBox<T>, RxGetter<T>, RxLockBox<T>

All Known Implementing Classes:

Breaker, ForwardingBox.Rx, ForwardingBox.RxLock, RxOrderedSet

public interface IObservable<T>
extends ObservableSource<T>

An object which can be supplied in an Observable form. Ideally, `io.reactivex.Observable` would be an interface, which would make this interface unnecessary. But so long as it isn't, this (combined with Rx) makes it fairly seamless to fix this.

Method Summary

Modifier and Type	Method and Description
Observable<T>	asObservable()
default void	subscribe(Observer<? super T> observer)
static <T> IObservable<T>	wrap(Observable<T> observable) Wraps an actual observable as an IObservable.

Method Detail

asObservable

Observable<T> asObservable()

subscribe

default void subscribe(Observer<? super T> observer)

Specified by:

subscribe in interface ObservableSource<T>

wrap

static <T> IObservable<T> wrap(Observable<T> observable)

Wraps an actual observable as an IObservable.