CachedStreamWrapper(Stream<T> _stream, Function _onListen)

Source 

CachedStreamWrapper(this._stream, this._onListen);