Callback when this executor is stopped. Returns true if successfully stopped, false otherwise.
@override Future<bool> onStop() async { await _subscription?.cancel(); _stream = null; return true; }