()
| 193 | } |
| 194 | |
| 195 | func ExampleConn_QueueSubscribe() { |
| 196 | nc, _ := nats.Connect(nats.DefaultURL) |
| 197 | defer nc.Close() |
| 198 | |
| 199 | received := 0 |
| 200 | |
| 201 | nc.QueueSubscribe("foo", "worker_group", func(_ *nats.Msg) { |
| 202 | received++ |
| 203 | }) |
| 204 | } |
| 205 | |
| 206 | func ExampleSubscription_AutoUnsubscribe() { |
| 207 | nc, _ := nats.Connect(nats.DefaultURL) |
nothing calls this directly
no test coverage detected