decoder

JSON decoder for streaming events

This module decodes JSON data from SSE events into typed StreamEvent values. It handles all Anthropic streaming event types including message_start, content_block_start, content_block_delta, content_block_stop, message_delta, message_stop, ping, and error events.

Types

DecodeError

</>

Error that can occur during event decoding

pub type DecodeError {
  JsonParseError(message: String)
  UnknownEventType(event_type: String)
  MissingField(field: String)
  InvalidFieldValue(field: String, message: String)
}

Constructors

```
JsonParseError(message: String)
```
JSON parsing failed
```
UnknownEventType(event_type: String)
```
Unknown event type
```
MissingField(field: String)
```
Missing required field

InvalidFieldValue(field: String, message: String)

Invalid field value

Values

decode_event

</>

pub fn decode_event(
  sse_event: sse.SseEvent,
) -> Result(streaming.StreamEvent, DecodeError)

Decode an SSE event into a StreamEvent