send<TResponse extends Object?> method

Future<TResponse> send<TResponse extends Object?>(Request<TResponse> request)

Sends a request to a single RequestHandler.

Make sure the RequestHandler is registered before calling this method.

This request can be wrapped by PipelineBehavior's see pipeline.

This will return TResponse.

Implementation

Future<TResponse> send<TResponse extends Object?>(
  Request<TResponse> request,
) async {
  final handler = _requestHandlerStore.getHandlerFor(request)
      as RequestHandler<TResponse, Request<TResponse>>;

  final pipelines = _pipelineBehaviorStore.getPipelines(request);

  FutureOr<TResponse> handle() => handler.handle(request);

  final RequestHandlerDelegate executionPlan = pipelines.fold(
    handle,
    (next, pipeline) => () => pipeline.handle(request, next),
  );

  final futureOrResult = executionPlan();
  final response =
      futureOrResult is Future ? await futureOrResult : futureOrResult;

  assert(
    response is TResponse,
    '$request expected a return type of $TResponse but '
    'got one of type ${response.runtimeType}. '
    'One of the registered pipelines is not correctly returning the '
    '`next()` call. Pipelines used: $pipelines',
  );

  return response;
}