Method pipeThroughQueryTransfers

erpc/query_pipe_through.go:106–122

(
	ctx context.Context,
	ups common.Upstream,
	req *evm.QueryTransfersRequest,
	onPage func(proto.Message) error,
)

}

func (qe *EvmQueryExecutor) pipeThroughQueryTransfers(
	ctx context.Context,
	ups common.Upstream,
	req *evm.QueryTransfersRequest,
	onPage func(proto.Message) error,
) error {
	client, ok := getGrpcBdsClient(ups)
	if !ok || client.QueryClient() == nil {
		return fmt.Errorf("upstream %s does not support query streaming", ups.Id())
	}
	qe.logger.Debug().Str("upstreamId", ups.Id()).Msgf("opening QueryTransfers stream to upstream")
	stream, err := client.QueryClient().QueryTransfers(ctx, req)
	if err != nil {
		return err
	}
	return qe.recvProtoStream(func() (proto.Message, error) { return stream.Recv() }, onPage, "eth_queryTransfers", ups.Id())
}

func (qe *EvmQueryExecutor) recvProtoStream(recv func() (proto.Message, error), onPage func(proto.Message) error, method string, upstreamId string) error {
	type cursorPage interface {