request<TData, TVars> method

  1. @override
Stream<OperationResponse<TData, TVars>> request<TData, TVars>(
  1. OperationRequest<TData, TVars> request, [
  2. NextTypedLink<TData, TVars>? forward
])
override

A function called when a request reaches this TypedLink

Implementation

@override
Stream<OperationResponse<TData, TVars>> request<TData, TVars>(
    OperationRequest<TData, TVars> request,
    [NextTypedLink<TData, TVars>? forward]) {
  _debugAssertUpdateResultTransferrable(request);

  return _handleStreamCommand<OperationResponse<TData, TVars>>(
      (port) => RequestCommand(port.sendPort, request),
      (response, sink) => sink.add(OperationResponse<TData, TVars>(
            operationRequest: response!.operationRequest,
            linkException: response.linkException,
            graphqlErrors: response.graphqlErrors,
            dataSource: response.dataSource,
            extensions: response.extensions,
            data: response.data,
          )));
}