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

Struct objWatcher

jetstream/object.go:1256–1259  ·  view source on GitHub ↗

Implementation for Watch

Source from the content-addressed store, hash-verified

1254
1255// Implementation for Watch
1256type objWatcher struct {
1257 updates chan *ObjectInfo
1258 sub *nats.Subscription
1259}
1260
1261// Updates returns the interior channel.
1262func (w *objWatcher) Updates() <-chan *ObjectInfo {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected