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

Method Done

js.go:3227–3227  ·  view source on GitHub ↗

Done signals end of execution.

()

Source from the content-addressed store, hash-verified

3225
3226 // Done signals end of execution.
3227 Done() <-chan struct{}
3228}
3229
3230type messageBatch struct {

Callers 15

TestPullSubscribeFetchBatchFunction · 0.95
PublishMsgMethod · 0.65
subscribeMethod · 0.65
FetchMethod · 0.65
FetchBatchMethod · 0.65
TestWSReaderFunction · 0.65
TestExpiredAuthenticationFunction · 0.65
TestNoPanicOnSrvPoolSizeChangingFunction · 0.65
TestLameDuckModeFunction · 0.65
PutMethod · 0.65
GetMethod · 0.65
ListMethod · 0.65

Implementers 1

messageBatchjs.go

Calls

no outgoing calls

Tested by 15

TestPullSubscribeFetchBatchFunction · 0.76
TestWSReaderFunction · 0.52
TestExpiredAuthenticationFunction · 0.52
TestNoPanicOnSrvPoolSizeChangingFunction · 0.52
TestLameDuckModeFunction · 0.52
ExampleJetStreamFunction · 0.52
TestCustomFlusherTimeoutFunction · 0.52
TestReceiveInfoRightAfterFirstPongFunction · 0.52
TestReceiveInfoWithEmptyConnectURLsFunction · 0.52
TestGetClientIDFunction · 0.52
TestTLSHandshakeFirstFunction · 0.52
TestWSConcurrentConnsFunction · 0.52