MCPcopy
hub / github.com/segmentio/kafka-go / joined

Struct joined

transport.go:918–922  ·  view source on GitHub ↗

joined is an implementation of the promise interface which merges results from multiple promises into one await call using a merger.

Source from the content-addressed store, hash-verified

916// joined is an implementation of the promise interface which merges results
917// from multiple promises into one await call using a merger.
918type joined struct {
919 promises []promise
920 requests []Request
921 merger protocol.Merger
922}
923
924func join(promises []promise, requests []Request, merger protocol.Merger) promise {
925 return &joined{

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected