Skip to content

Commit

Permalink
Update Release Notes for 0.5.8 (#1462)
Browse files Browse the repository at this point in the history
Co-authored-by: Lancetnik <[email protected]>
  • Loading branch information
1 parent 82853db commit f6b3336
Showing 1 changed file with 78 additions and 0 deletions.
78 changes: 78 additions & 0 deletions docs/docs/en/release.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,84 @@ hide:
---

# Release Notes
## 0.5.8

### What's Changed

This is the time for a new **NATS** features! **FastStream** supports **NATS Key-Value** and **Object Storage** subscribption features in a native way now (big thx for @sheldygg)!

1. KeyValue creation and watching API added (you can read updated [documentation section](https://faststream.airt.ai/latest/nats/jetstream/key-value/) for changes):

```python
from faststream import FastStream, Logger
from faststream.nats import NatsBroker

broker = NatsBroker()
app = FastStream(broker)

@broker.subscriber("some-key", kv_watch="bucket")
async def handler(msg: int, logger: Logger):
logger.info(msg)

@app.after_startup
async def test():
kv = await broker.key_value("bucket")
await kv.put("some-key", b"1")
```

2. ObjectStore API added as well (you can read updated [documentation section](https://faststream.airt.ai/latest/nats/jetstream/object/) for changes):

```python
from faststream import FastStream, Logger
from faststream.nats import NatsBroker

broker = NatsBroker()
app = FastStream(broker)

@broker.subscriber("file-bucket", obj_watch=True)
async def handler(filename: str, logger: Logger):
logger.info(filename)

@app.after_startup
async def test():
object_store = await broker.object_storage("file-bucket")
await object_store.put("some-file.txt", b"1")
```

3. Also now you can use just `pull_sub=True` instead of `pull_sub=PullSub()` in basic case:

```python
from faststream import FastStream, Logger
from faststream.nats import NatsBroker

broker = NatsBroker()
app = FastStream(broker)

@broker.subscriber("test", stream="stream", pull_sub=True)
async def handler(msg, logger: Logger):
logger.info(msg)
```

Finally, we have a new feature, related to all brokers: special flag to suppress automatic RPC and reply_to responses:

```python
@broker.subscriber("tests", no_reply=True)
async def handler():
....

# will fail with timeout, because there is no automatic response
msg = await broker.publish("msg", "test", rpc=True)
```

* fix: when headers() returns None in AsyncConfluentParser, replace it with an empty tuple by @andreaimprovised in https://github.com/airtai/faststream/pull/1460
* Implement Kv/Obj watch. by @sheldygg in https://github.com/airtai/faststream/pull/1383
* feat: add subscriber no-reply option by @Lancetnik in https://github.com/airtai/faststream/pull/1461

### New Contributors
* @andreaimprovised made their first contribution in https://github.com/airtai/faststream/pull/1460

**Full Changelog**: https://github.com/airtai/faststream/compare/0.5.7...0.5.8

## 0.5.7

### What's Changed
Expand Down

0 comments on commit f6b3336

Please sign in to comment.