tomaszpolanski

class OnErrorResumeNextStreamTransformer2<T>
    extends StreamTransformerBase<T, T> {
  final StreamTransformer<T, T> transformer;

  // From the orginal version parameter was changed from `Stream<T> recoveryStream` to `Stream<T> Function (dynamic error) recoveryStream`
  OnErrorResumeNextStreamTransformer2(Stream<T> Function (dynamic error) recoveryStream)
      : transformer = _buildTransformer(recoveryStream);

  @override
  Stream<T> bind(Stream<T> stream) => transformer.bind(stream);