PipeObservable<T, R> class abstract

PipeObservable is a pipeline that transform an input observable to an output observable.

The input observable is the source that implements Observable<T>, and the output observable is itself that implements Observable<R>.

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

  const PipeObservable({
    required this.source,
  });

  final Observable<T> source;
}

Example:

class ObservableMap<T, R> extends PipeObservable<T, R> {
  
  const ObservableMap({
    required this.convert,
    required super.source,
  });

  final R Function(T) convert;

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

ObservableMap<T, R> is a PipeObservable, since it transform an input Observable<T> to an output Observable<R>.

Implemented types

• Observable<R>

Available Extensions

• ObservableAsStatesX
• ObservableX

Constructors

PipeObservable({required Observable<T> source})

Create a PipeObservable with source.

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

source → Observable<T>

The input observable

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