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

Method PublishAsync

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

PublishAsync publishes a message to JetStream and returns a PubAckFuture. The data should not be changed until the PubAckFuture has been processed.

(subj string, data []byte, opts ...PubOpt)

Source from the content-addressed store, hash-verified

47 // PublishAsync publishes a message to JetStream and returns a PubAckFuture.
48 // The data should not be changed until the PubAckFuture has been processed.
49 PublishAsync(subj string, data []byte, opts ...PubOpt) (PubAckFuture, error)
50
51 // PublishMsgAsync publishes a Msg to JetStream and returns a PubAckFuture.
52 // The message should not be changed until the PubAckFuture has been processed.

Callers 14

ExampleJetStreamFunction · 0.65
TestNoRaceJetStreamPushFlowControl_SubscribeAsyncAndChannelFunction · 0.65
TestNoRaceJetStreamChanSubscribeStallFunction · 0.65
TestPublishAsyncWithTTLFunction · 0.65
TestJetStreamPublishAsyncFunction · 0.65
TestPublishAsyncResetPendingOnReconnectFunction · 0.65
TestPublishAsyncAckTimeoutFunction · 0.65
TestPublishAsyncClearStallFunction · 0.65
TestPublishAsyncRetryInErrHandlerFunction · 0.65
TestJetStreamPublishAsyncPerfFunction · 0.65
TestPublishAsyncRetryFunction · 0.65
TestJetStreamCleanupPublisherFunction · 0.65

Calls

no outgoing calls

Tested by 14

ExampleJetStreamFunction · 0.52
TestNoRaceJetStreamPushFlowControl_SubscribeAsyncAndChannelFunction · 0.52
TestNoRaceJetStreamChanSubscribeStallFunction · 0.52
TestPublishAsyncWithTTLFunction · 0.52
TestJetStreamPublishAsyncFunction · 0.52
TestPublishAsyncResetPendingOnReconnectFunction · 0.52
TestPublishAsyncAckTimeoutFunction · 0.52
TestPublishAsyncClearStallFunction · 0.52
TestPublishAsyncRetryInErrHandlerFunction · 0.52
TestJetStreamPublishAsyncPerfFunction · 0.52
TestPublishAsyncRetryFunction · 0.52
TestJetStreamCleanupPublisherFunction · 0.52