reading-streams

What problem does it solve?

This Skill provides a robust set of reading patterns for durable streams, enabling client applications to fetch, stream, and process data from the Durable Streams service with flexibility across catch-up and live modes.

Core Features & Use Cases

• Readable consumption via stream() for both catch-up and live scenarios.
• Multiple consumption methods: .json(), .text(), .body(), .jsonStream(), .textStream(), .bodyStream(), and .subscribeJson(), .subscribeText(), .subscribeBytes().
• Supports various live modes (false, true, "long-poll", "sse"), offset management, and error recovery to handle interruptions gracefully.

Quick Start

Start by importing the Durable Streams client and calling stream with a stream URL, an offset (for example "-1"), and a live mode to begin consuming data.