Nats jetstream publish async

[lisablack1]

Hi can some one provide any better example for nats publish in asynchronous

i have tried in the below format , its keep on going to else condition ,

streamContext, err := connection.JetStream(nats.PublishAsyncMaxPending(1000)) <<--- wait for 1000 ack pending msgs

am i doing anything wrong , any suggestions would be appreciated

    for i:=0;i<100000;i++{
        if streamContext.PublishAsyncPending() < 1000 {
            _, err = streamContext.PublishAsync(newSubjectName, bytesInfo) //sample msg in bytes format
    
            if err != nil {
                log.Println("publish error:", err)
                continue
            }
            log.Println("msg published")
        } else {
            log.Println("PublishAsyncPending:", streamContext.PublishAsyncPending())
            time.Sleep(time.Millisecond * 10)
            continue
        }
    } 

[derekcollison]

The system will automatically gate if the pubacks outstanding is >= the max, no need to test.

[lisablack1]

what is maximum value for AsyncMaxPending we can provide ? , will it cause any blocks or holds any memory if it reaches to the max and waiting for acks

[derekcollison]

No limits, will just hold all pending acks in memory so they can be checked. If the client reaches the max it will wait til pending is below the threshold.