Streamable

streamable.dart

class Streamable<T> extends Subject<T> implements ValueStream<T> {
  Streamable(this._subject) : super(_subject, _subject);

  final BehaviorSubject<T> _subject;

  @override
  Subject<R> createForwardingSubject<R>({
    void Function()? onListen,
    void Function()? onCancel,
    bool sync = false,
  }) =>
      _subject.createForwardingSubject(
        onListen: onListen,
        onCancel: onCancel,
        sync: sync,
      );

  @override
  ErrorAndStackTrace? get errorAndStackTrace => _subject.errorAndStackTrace;

  @override
  ValueWrapper<T>? get valueWrapper => _subject.valueWrapper;
}

class GeneralClass<T> extends Streamable<T> {
  GeneralClass() : super(BehaviorSubject<T>());
}

void main() {
  test('GeneralClassTest', () async {
    final general2 = GeneralClass<String>();

    expect(general2, isA<Stream>());

    // should emit haha, hoho, hehe
    expectLater(
      general2,
      emitsInOrder(['haha', 'hoho', 'hehe']),
    );

    general2
      ..add('haha') // Adding haha
      ..add('hoho') // Adding hoho
      ..add('hehe'); // Adding hehe
  });
}