IObservable<T>, which exposes a
Subscribemethod which will notify you when the value changes.
asyncworks where you are waiting on something to happen then you handle the result and do some logic with it, but this can be represented as a data push opposed to a data pull.
Observer<T>(does something on a stream)
IObservable<T>implementations, but how on earth do we create an observable implementation to use?
Subject<T>or if using
UniRxcreate them as
ReactiveProperty<T>(which is a handy wrapper around
Subject<T>and some other interfaces).
Observableclass, like so:
Whereextension which will filter the incoming values and only progress the stream if the predicate matches.