Start consuming from the clientapi
()
| 61 | |
| 62 | // Start consuming from the clientapi |
| 63 | func (t *OutputTypingConsumer) Start() error { |
| 64 | return jetstream.JetStreamConsumer( |
| 65 | t.ctx, t.jetstream, t.topic, t.durable, t.onMessage, |
| 66 | nats.DeliverAll(), nats.ManualAck(), nats.HeadersOnly(), |
| 67 | ) |
| 68 | } |
| 69 | |
| 70 | // onMessage is called in response to a message received on the typing |
| 71 | // events topic from the client api. |