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