request<TData, TVars> method

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

A function called when a request reaches this TypedLink

Implementation

@override
Stream<OperationResponse<TData, TVars>> request<TData, TVars>(
  OperationRequest<TData, TVars> operationRequest, [
  forward,
]) =>
    cache.watchQuery(operationRequest).map(
          (data) => OperationResponse(
            operationRequest: operationRequest,
            data: data,
            dataSource: DataSource.Cache,
          ),
        );