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