Method PublishAsyncComplete

js.go:59–59

PublishAsyncComplete returns a channel that will be closed when all outstanding messages are ack'd.

()

	// PublishAsyncComplete returns a channel that will be closed when all outstanding messages are ack'd.
	PublishAsyncComplete() <-chan struct{}

	// CleanupPublisher will cleanup the publishing side of JetStreamContext.
	//