getEventStreamForTask method
Implementation
@override
Stream<BackgroundEvent> getEventStreamForTask(String id) {
return taskStreamMap[id] ??= BehaviorSubject()
..addStream(Rx.merge([_progressStream, _resultStream]).where((event) => event["taskId"] == id).map((event) => BackgroundEvent.fromMap(event)));
}