Observable<T> constructor

Observable<T>()

Implementation

Observable() {
  _controller = StreamController<ObservableChange<T>>.broadcast();
}