Method PublishAsyncPending

js.go:56–56

PublishAsyncPending returns the number of async publishes outstanding for this context.

()

	// PublishAsyncPending returns the number of async publishes outstanding for this context.
	PublishAsyncPending() int

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