execute method

void execute(
  1. Observer<T> observer, [
  2. Params? params
])

Subscribes to the Observerable with the Observer callback functions.

Implementation

void execute(Observer<T> observer, [Params? params]) async {
  final StreamSubscription subscription = (await buildUseCaseStream(params))
      .listen(observer.onNext,
          onDone: observer.onComplete, onError: observer.onError);
  _addSubscription(subscription);
}