@@ -787,9 +787,9 @@ abstract class Rx {
787
787
///
788
788
/// ### Example
789
789
///
790
- /// Rx.range(1, 3).listen((i) => print(i); // Prints 1, 2, 3
790
+ /// Rx.range(1, 3).listen((i) => print(i)) ; // Prints 1, 2, 3
791
791
///
792
- /// Rx.range(3, 1).listen((i) => print(i); // Prints 3, 2, 1
792
+ /// Rx.range(3, 1).listen((i) => print(i)) ; // Prints 3, 2, 1
793
793
static Stream <int > range (int startInclusive, int endInclusive) =>
794
794
RangeStream (startInclusive, endInclusive);
795
795
@@ -803,7 +803,7 @@ abstract class Rx {
803
803
///
804
804
/// RepeatStream((int repeatCount) =>
805
805
/// Stream.value('repeat index: $repeatCount'), 3)
806
- /// .listen((i) => print(i); // Prints 'repeat index: 0, repeat index: 1, repeat index: 2'
806
+ /// .listen((i) => print(i)) ; // Prints 'repeat index: 0, repeat index: 1, repeat index: 2'
807
807
static Stream <T > repeat <T >(Stream <T > Function (int repeatIndex) streamFactory,
808
808
[int ? count]) =>
809
809
RepeatStream <T >(streamFactory, count);
@@ -946,7 +946,7 @@ abstract class Rx {
946
946
/// ### Example
947
947
///
948
948
/// Rx.timer('hi', Duration(minutes: 1))
949
- /// .listen((i) => print(i); // print 'hi' after 1 minute
949
+ /// .listen((i) => print(i)) ; // print 'hi' after 1 minute
950
950
static Stream <T > timer <T >(T value, Duration duration) =>
951
951
TimerStream <T >(value, duration);
952
952
0 commit comments