runAsync method

@override Future<void> runAsync(FutureOr<void> callback())

Runs callback and adds events to stream using the following sequence:

• busy, delaying,ready.

Implementation

@override
Future<void> runAsync(FutureOr<void> Function() callback) async {
  if (current.state.isReady) {
    try {
      _add(busy);
      await callback();
      _add(delaying);
    } catch (error, stacktrace) {
      _controller.addError(error, stacktrace);
    } finally {
      _timer = Timer(duration, () {
        _add(ready);
      });
    }
  }
}