PublishAsync performs an asynchronous publish to a stream and returns [PubAckFuture] interface. It accepts subject name (which must be bound to a stream) and message payload.
(subj string, data []byte, opts ...PublishOpt)
| 265 | // [PubAckFuture] interface. It accepts subject name (which must be bound |
| 266 | // to a stream) and message payload. |
| 267 | func (js *jetStream) PublishAsync(subj string, data []byte, opts ...PublishOpt) (PubAckFuture, error) { |
| 268 | return js.PublishMsgAsync(&nats.Msg{Subject: subj, Data: data}, opts...) |
| 269 | } |
| 270 | |
| 271 | // PublishMsgAsync performs an asynchronous publish to a stream and |
| 272 | // returns [PubAckFuture] interface. It accepts subject name (which must |
nothing calls this directly
no test coverage detected