observe method

@override Disposable observe(OnData<T> onData)

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

// start observe
final observation = observable.observe((data) {
  print('onData: $data');
});

// stop observe
observation.dispose();

Implementation

@override
Disposable observe(OnData<T> onData) {
  if (_disposed) {
    throw StateError("Subject is disposed and can't be observed.");
  }
  return _subject.observe(onData);
}