getEventStreamForTask method

  1. @override
Stream<BackgroundEvent> getEventStreamForTask(
  1. String id
)
override

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)));
}