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

Method toJSMsg

jetstream/message.go:530–535  ·  view source on GitHub ↗

toJSMsg converts core [nats.Msg] to [jetStreamMsg], exposing JetStream-specific operations

(msg *nats.Msg)

Source from the content-addressed store, hash-verified

528
529// toJSMsg converts core [nats.Msg] to [jetStreamMsg], exposing JetStream-specific operations
530func (js *jetStream) toJSMsg(msg *nats.Msg) *jetStreamMsg {
531 return &jetStreamMsg{
532 msg: msg,
533 js: js,
534 }
535}

Callers 5

apiRequestMethod · 0.95
ConsumeMethod · 0.80
ConsumeMethod · 0.80
NextMethod · 0.80
fetchMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected