Overview
This release introduces JetStream support, including:
- JetStream management API support (Streams and Consumers)
- Publishing messages to streams and getting/deleting individual messages
- Pull consumer support with
fetch()
It also features reworked errors, all namespaced under NatsError
and JetStreamError
.
What's Changed
- Add basic JetStream context by @Jarema in #67
- Fix another promise leak by @mtmk in #69
- Fixed websocket path by @mtmk in #68
- Add jetstream request by @Jarema in #71
- Add CRUD operation on streams by @piotrpio in #72
- Additional stream APIs by @piotrpio in #73
- Fixed missing public access modifiers by @piotrpio in #74
- Add fetching individual messages from stream by @piotrpio in #75
- Fix race in Connect by @piotrpio in #77
- Add deleting messages and purging a stream by @piotrpio in #76
- Refactor core nats errors by @piotrpio in #78
- Change NatsSubscription to a throwing AsyncSequence by @piotrpio in #79
- Refactor JetStream errors, add docs by @piotrpio in #80
- Add queue subscribe by @piotrpio in #81
- Add jetstream consumer management by @piotrpio in #83
- Add fetching messages from JetStream by @piotrpio in #87
Full Changelog: v0.3.0...v0.4.0