Packages

beam_weaver

0.1.0
0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Elixir-native LangChain, LangGraph, and DeepAgents for traceable LLM apps: OTP workflows, tools, memory, human-in-the-loop, streaming, custom clients/adapters, minimal deps, and WeaveScope tracing.

Current section

Files

Jump to
Readme
14 Versions
7 Dependencies
Dependants
Files
Activity
beam_weaver examples streaming_agent.exs
Raw

examples/streaming_agent.exs 

alias BeamWeaver.Core.ChatModel

alias BeamWeaver.Core.Message

alias BeamWeaver.Stream.Envelope



defmodule BeamWeaver.Examples.StreamingAgent.Model do

  @behaviour ChatModel



  defstruct []



  def invoke(%__MODULE__{}, _messages, _opts), do: {:ok, Message.assistant("streamed")}

end



defmodule BeamWeaver.Examples.StreamingAgent do

  use BeamWeaver.Agent



  model(%BeamWeaver.Examples.StreamingAgent.Model{})

end



{:ok, events} =

  BeamWeaver.Examples.StreamingAgent.stream_events(%{messages: [Message.user("hello")]})



events

|> Enum.filter(&match?(%Envelope{}, &1))

|> length()

|> IO.puts()