run method

Implementation

@override
Stream<TProgress> run() {
  final controller = StreamController<TProgress>();
  startWorking(controller);
  return controller.stream;
}