AgentSessionManager.Rendering.Sinks.CallbackSink
(AgentSessionManager v0.8.0)
Copy Markdown
View Source
A sink that forwards events to a callback function.
Useful for programmatic consumption of event streams — testing, forwarding to a GenServer, broadcasting via PubSub, etc.
Options
:callback— A function(event, iodata) -> term(). Required.
Example
Rendering.stream(events,
renderer: {PassthroughRenderer, []},
sinks: [{CallbackSink, [callback: fn event, _iodata -> handle(event) end]}]
)