asDisposable method

Disposable asDisposable()

Implementation

Disposable asDisposable() => Disposable.create(
    this, (StreamSubscription<T> s) => s.cancel());