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

Method Messages

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

Messages returns a channel on which messages will be published.

()

Source from the content-addressed store, hash-verified

3219type MessageBatch interface {
3220 // Messages returns a channel on which messages will be published.
3221 Messages() <-chan *Msg
3222
3223 // Error returns an error encountered when fetching messages.
3224 Error() error

Callers 1

TestPullSubscribeFetchBatchFunction · 0.95

Implementers 1

messageBatchjs.go

Calls

no outgoing calls

Tested by 1

TestPullSubscribeFetchBatchFunction · 0.76