execute method
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);
}