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

Method PublishAsync

jetstream/jetstream.go:90–90  ·  view source on GitHub ↗

PublishAsync performs a publish to a stream and returns [PubAckFuture] interface, not blocking while waiting for an acknowledgement. It accepts subject name (which must be bound to a stream) and message payload. PublishAsync does not guarantee that the message has been received by the server. It on

(subject string, payload []byte, opts ...PublishOpt)

Source from the content-addressed store, hash-verified

88 // sent to the server and thus messages can be stored in the stream
89 // out of order in case of retries.
90 PublishAsync(subject string, payload []byte, opts ...PublishOpt) (PubAckFuture, error)
91
92 // PublishMsgAsync performs a publish to a stream and returns
93 // [PubAckFuture] interface, not blocking while waiting for an

Implementers 2

jsjs.go
jetStreamjetstream/jetstream.go

Calls

no outgoing calls