statusAsStream method

Stream<VideoEncodingJobEntity> statusAsStream(
  1. int token, {
  2. Duration checkInterval = const Duration(seconds: 5),
})

Returns processing job as Stream

token from VideoEncodingResultEntity.token checkInterval check status interval

Implementation

Stream<VideoEncodingJobEntity> statusAsStream(
  int token, {
  Duration checkInterval = const Duration(seconds: 5),
}) {
  final StreamController<VideoEncodingJobEntity> controller =
      StreamController.broadcast();

  Timer(checkInterval,
      () => _statusTimerCallback(token, checkInterval, controller));

  return controller.stream;
}