PublishAsync publishes a message to JetStream and returns a PubAckFuture
(subj string, data []byte, opts ...PubOpt)
| 1003 | |
| 1004 | // PublishAsync publishes a message to JetStream and returns a PubAckFuture |
| 1005 | func (js *js) PublishAsync(subj string, data []byte, opts ...PubOpt) (PubAckFuture, error) { |
| 1006 | return js.PublishMsgAsync(&Msg{Subject: subj, Data: data}, opts...) |
| 1007 | } |
| 1008 | |
| 1009 | const defaultStallWait = 200 * time.Millisecond |
| 1010 |
nothing calls this directly
no test coverage detected