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

Function join

transport.go:924–930  ·  view source on GitHub ↗
(promises []promise, requests []Request, merger protocol.Merger)

Source from the content-addressed store, hash-verified

922}
923
924func join(promises []promise, requests []Request, merger protocol.Merger) promise {
925 return &joined{
926 promises: promises,
927 requests: requests,
928 merger: merger,
929 }
930}
931
932func (p *joined) await(ctx context.Context) (Response, error) {
933 results := make([]interface{}, len(p.promises))

Callers 2

createGroupFunction · 0.85
roundTripMethod · 0.85

Calls

no outgoing calls

Tested by 1

createGroupFunction · 0.68