Function NewGRPCCollector

modules/frontend/pipeline/collector_grpc.go:22–30

(next AsyncRoundTripper[combiner.PipelineResponse], consumers int, maxSegmentSize int, combiner combiner.GRPCCombiner[T], send func(T) error)

}

func NewGRPCCollector[T combiner.TResponse](next AsyncRoundTripper[combiner.PipelineResponse], consumers int, maxSegmentSize int, combiner combiner.GRPCCombiner[T], send func(T) error) *GRPCCollector[T] {
	return &GRPCCollector[T]{
		next:           next,
		combiner:       combiner,
		consumers:      consumers,
		maxSegmentSize: maxSegmentSize,
		send:           send,
	}
}

// RoundTrip implements the http.RoundTripper interface
func (c GRPCCollector[T]) RoundTrip(req *http.Request) error {