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

Method await

transport.go:876–876  ·  view source on GitHub ↗

Waits until the promise is resolved, rejected, or the context canceled.

(context.Context)

Source from the content-addressed store, hash-verified

874type promise interface {
875 // Waits until the promise is resolved, rejected, or the context canceled.
876 await(context.Context) (Response, error)
877}
878
879// async is an implementation of the promise interface which supports resolving

Callers 4

roundTripMethod · 0.95
discoverMethod · 0.65
sendRequestMethod · 0.65
awaitMethod · 0.65

Implementers 2

rejectedtransport.go
joinedtransport.go

Calls

no outgoing calls

Tested by

no test coverage detected