MultiSourcePipeObservable<T, R> class abstract

MultiSourcePipeObservable is a pipeline that transform multiple input observables to an output observable.

The multiple input observables is a list of source, each source implements Observable<T>, and the output observable is itself that implements Observable<R>.

abstract class MultiSourcePipeObservable<T, R> implements Observable<R> {

  const MultiSourcePipeObservable({
    required this.sources,
  });

  final List<Observable<T>> sources; 
}

Example:

class ObservableCombine<T, R> extends MultiSourcePipeObservable<T, R> {

  const ObservableCombine({
    required super.sources,
    required this.combiner,
  });

  final R Function(List<T> items) combiner;

  @override
  Disposable observe(OnData<R> onData) {  ... }
}

ObservableCombine<T, R> is a MultiSourcePipeObservable, since it transform multiple input Observable<T> to an output Observable<R>.

Implemented types

• Observable<R>

Available Extensions

• ObservableAsStatesX
• ObservableX

Constructors

MultiSourcePipeObservable({required List<Observable<T>> sources})

Create a MultiSourcePipeObservable with sources.

const

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

sources → List<Observable<T>>

The input observables

final

Methods

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

observe(OnData<R> onData) → Disposable

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

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited