TaskProcessor constructor

TaskProcessor({
  1. required TaskRegistry registry,
  2. RetryStrategy? retryStrategy,
  3. List<Middleware> middleware = const [],
  4. PayloadSigner? signer,
  5. TaskPayloadEncoderRegistry? encoderRegistry,
  6. TaskPayloadEncoder argsEncoder = const JsonTaskPayloadEncoder(),
  7. Iterable<TaskPayloadEncoder> additionalEncoders = const [],
  8. int? randomSeed,
})

Creates a runtime-neutral task processor.

Implementation

TaskProcessor({
  required this.registry,
  RetryStrategy? retryStrategy,
  List<Middleware> middleware = const [],
  this.signer,
  TaskPayloadEncoderRegistry? encoderRegistry,
  TaskPayloadEncoder argsEncoder = const JsonTaskPayloadEncoder(),
  Iterable<TaskPayloadEncoder> additionalEncoders = const [],
  int? randomSeed,
}) : retryStrategy = retryStrategy ?? ExponentialJitterRetryStrategy(),
     middleware = List.unmodifiable(middleware),
     payloadEncoders = ensureTaskPayloadEncoderRegistry(
       encoderRegistry,
       argsEncoder: argsEncoder,
       additionalEncoders: additionalEncoders,
     ),
     _random = math.Random(randomSeed);