handler method

Future<void> handler(
  1. JobHandler handler, {
  2. JobResourceRequirements? opts,
  3. List<JobHandler> middlewares = const [],
})

Create a handler function that will be executed when a job is submitted.

Implementation

Future<void> handler(JobHandler handler,
    {JobResourceRequirements? opts,
    List<JobHandler> middlewares = const []}) async {
  opts ??= JobResourceRequirements();

  final registrationRequest = $jp.RegistrationRequest(
    jobName: name,
    requirements: opts._toWire(),
  );

  final composedHandler =
      composeMiddleware([...middlewares, handler], JobContext.fromCtx);

  var worker = JobWorker(registrationRequest, composedHandler);

  await worker.start();
}