search

romanchechyotkin / nats.ocaml

OCaml client for NATS, the cloud native messaging system.
Apache License 2.0
10 stars 2 forks source link

Drain mechanism #16

Open dx3mod opened 2 months ago

dx3mod commented 2 months ago

Implement drain incoming messages on close. https://docs.nats.io/using-nats/developer/receiving/drain

See nats.go

// Drain connection (Preferred for responders)
// Close() not needed if this is called.
nc.Drain()
dx3mod commented 4 days ago

Implemented unsub in commit d0b65eecd39ee959779eaf36f81b9ff9761f02f8.