File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -13,14 +13,14 @@ import 'package:rxdart/src/utils/notification.dart';
1313///
1414/// Stream<Notification<int>>
1515/// .fromIterable([Notification.onData(1), Notification.onDone()])
16- /// .transform(dematerializeTransformer ())
16+ /// .transform(DematerializeStreamTransformer ())
1717/// .listen((i) => print(i)); // Prints 1
1818///
1919/// ### Error example
2020///
2121/// Stream<Notification<int>>
2222/// .fromIterable([Notification.onError(Exception(), null)])
23- /// .transform(dematerializeTransformer ())
23+ /// .transform(DematerializeStreamTransformer ())
2424/// .listen(null, onError: (e, s) { print(e) }); // Prints Exception
2525class DematerializeStreamTransformer <T >
2626 extends StreamTransformerBase <Notification <T >, T > {
Original file line number Diff line number Diff line change @@ -12,7 +12,7 @@ import 'package:rxdart/src/utils/notification.dart';
1212/// ### Example
1313///
1414/// Stream<int>.fromIterable([1])
15- /// .transform(materializeTransformer ())
15+ /// .transform(MaterializeStreamTransformer ())
1616/// .listen((i) => print(i)); // Prints onData & onDone Notification
1717class MaterializeStreamTransformer <T >
1818 extends StreamTransformerBase <T , Notification <T >> {
Original file line number Diff line number Diff line change @@ -8,7 +8,7 @@ import 'dart:async';
88/// Stream.value(1),
99/// TimerStream(2, Duration(minutes: 2))
1010/// ])
11- /// .transform(skipUntilTransformer (TimerStream(1, Duration(minutes: 1))))
11+ /// .transform(SkipUntilStreamTransformer (TimerStream(1, Duration(minutes: 1))))
1212/// .listen(print); // prints 2;
1313class SkipUntilStreamTransformer <T , S > extends StreamTransformerBase <T , T > {
1414 final StreamTransformer <T , T > _transformer;
You can’t perform that action at this time.
0 commit comments