onRestart method

@override Future<bool> onRestart()

Callback when this executor is to be restarted. Returns true if the executor is ready to restart (default), false otherwise.

Subclasses should override this, to implement any configuration to be done before restarting.

Implementation

@override
Future<bool> onRestart() async {
  await _subscription?.cancel();
  _stream = null;
  return true;
}