asDisposable method

Disposable asDisposable()

Implementation

Disposable asDisposable() => Disposable.create(
    this, (StreamController<T> s) => s.close());