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

Method Stop

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

Stop unsubscribes from the stream and cancels subscription. No more messages will be received after calling this method. All messages that are already in the buffer are discarded.

()

Source from the content-addressed store, hash-verified

59 // No more messages will be received after calling this method.
60 // All messages that are already in the buffer are discarded.
61 Stop()
62
63 // Drain unsubscribes from the stream and cancels subscription.
64 // All messages that are already in the buffer will be processed in callback function.

Callers 4

ConsumeMethod · 0.65
NextMethod · 0.65
StopMethod · 0.65
cleanupMethod · 0.65

Implementers 3

pushSubscriptionjetstream/push.go
pullSubscriptionjetstream/pull.go
orderedSubscriptionjetstream/ordered.go

Calls

no outgoing calls

Tested by

no test coverage detected