MCPcopy
hub / github.com/nats-io/nats.go / PublishAsyncComplete

Method PublishAsyncComplete

jetstream/jetstream.go:111–111  ·  view source on GitHub ↗

PublishAsyncComplete returns a channel that will be closed when all outstanding asynchronously published messages are acknowledged by the server.

()

Source from the content-addressed store, hash-verified

109 // outstanding asynchronously published messages are acknowledged by the
110 // server.
111 PublishAsyncComplete() <-chan struct{}
112
113 // CleanupPublisher will clean up the publishing side of JetStreamContext.
114 //

Callers 9

PutMethod · 0.65
TestPublishMsgAsyncFunction · 0.65
TestPublishAsyncRetryFunction · 0.65
TestSubjectsFilterPagingFunction · 0.65

Implementers 2

jsjs.go
jetStreamjetstream/jetstream.go

Calls

no outgoing calls