Publisher<T> class

Publisher emits to an observer only those items that are emitted by the source Observable(s) subsequent to the time of the subscription.

Modified from: https://reactivex.io/documentation/subject.html

Implemented types

• Subject<T>

Available extensions

• DisposableX
• ObservableAsStatesX
• ObservableX

Constructors

Publisher.new()

Properties

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

addWith({VoidCallback? beforeDispose, VoidCallback? afterDispose}) → Disposable

Available on Disposable, provided by the DisposableX extension

asStates() → States<T>

Available on Observable<T>, provided by the ObservableAsStatesX extension

Cast an Observable to States.

cast<R>() → Observable<R>

Available on Observable<T>, provided by the ObservableX extension

Mapping source Observable<T> to Observable<R> by casting each item as R.

dispose() → void

override

distinct([Equals<T>? equals]) → Observable<T>

Available on Observable<T>, provided by the ObservableX extension

Mirror an Observable and emit only those items that changed (meaning item is distinct from previous emitted one).

distinctMap<R>(R convert(T), {Equals<R>? equals}) → Observable<R>

Available on Observable<T>, provided by the ObservableX extension

DistinctMap is composition of Map and Distinct.

map<R>(R convert(T)) → Observable<R>

Available on Observable<T>, provided by the ObservableX extension

Transform the items emitted by an Observable by applying a function to each item.

multicast({Subject<T> createSubject()?}) → Observable<T>

Available on Observable<T>, provided by the ObservableX extension

Multicast observable make multiple observers share single source subscription.

multicastReplay(int bufferSize) → Observable<T>

Available on Observable<T>, provided by the ObservableX extension

Multicast replay observable make multiple observers share single source subscription.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

observe(OnData<T> onData) → Disposable

Use observable.observe to start observe an observable, use returned observation to stop observe.

override

onData(T data) → void

Use observer.onData to notify observer.

override

skip(int n) → Observable<T>

Available on Observable<T>, provided by the ObservableX extension

Suppress the first n items emitted by an Observable.

toString() → String

A string representation of this object.

inherited

where(bool test(T)) → Observable<T>

Available on Observable<T>, provided by the ObservableX extension

Emit only those items from an Observable that pass a predicate test.

Operators

operator ==(Object other) → bool

The equality operator.

inherited