subscribe method

  1. @override
Disposable subscribe(
  1. Observer<T> observer
)
override

Subscribes with the provided observer.

Implementation

@override
Disposable subscribe(Observer<T> observer) {
  final subscriber = createSubscriber(observer);
  subject.subscribe(subscriber);
  return subscriber;
}