diff --git a/lib/src/streams/timer.dart b/lib/src/streams/timer.dart index c456b6673..1472faeaa 100644 --- a/lib/src/streams/timer.dart +++ b/lib/src/streams/timer.dart @@ -1,5 +1,7 @@ import 'dart:async'; +import 'package:clock/clock.dart'; + /// Emits the given value after a specified amount of time. /// /// ### Example @@ -25,7 +27,7 @@ class TimerStream extends Stream { } static StreamController _buildController(T value, Duration duration) { - final watch = Stopwatch(); + final watch = clock.stopwatch(); Timer? timer; late StreamController controller; Duration? totalElapsed = Duration.zero; diff --git a/lib/src/transformers/time_interval.dart b/lib/src/transformers/time_interval.dart index c0b44d3db..b1f00beb8 100644 --- a/lib/src/transformers/time_interval.dart +++ b/lib/src/transformers/time_interval.dart @@ -1,10 +1,11 @@ import 'dart:async'; +import 'package:clock/clock.dart'; import 'package:rxdart/src/utils/forwarding_sink.dart'; import 'package:rxdart/src/utils/forwarding_stream.dart'; class _TimeIntervalStreamSink extends ForwardingSink> { - final _stopwatch = Stopwatch(); + final _stopwatch = clock.stopwatch(); @override void onData(S data) { diff --git a/lib/src/transformers/timestamp.dart b/lib/src/transformers/timestamp.dart index 3a1560f8e..a4d33c6fa 100644 --- a/lib/src/transformers/timestamp.dart +++ b/lib/src/transformers/timestamp.dart @@ -1,5 +1,7 @@ import 'dart:async'; +import 'package:clock/clock.dart'; + class _TimestampStreamSink implements EventSink { final EventSink> _outputSink; @@ -7,7 +9,7 @@ class _TimestampStreamSink implements EventSink { @override void add(S data) { - _outputSink.add(Timestamped(DateTime.now(), data)); + _outputSink.add(Timestamped(clock.now(), data)); } @override diff --git a/pubspec.yaml b/pubspec.yaml index 62c1ca2af..b9d651ab8 100644 --- a/pubspec.yaml +++ b/pubspec.yaml @@ -8,6 +8,9 @@ repository: https://github.com/ReactiveX/rxdart environment: sdk: '>=2.12.0 <3.0.0' +dependencies: + clock: ^1.1.0 + dev_dependencies: build_runner: ^2.1.2 build_web_compilers: ^3.0.0