Packages

claude_agent_sdk

0.9.0
0.18.0 0.17.2 0.17.1 0.17.0 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.2 0.9.1 0.9.0 0.8.1 0.8.0 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.10 0.6.9 0.6.8 0.6.7 0.6.6 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.0 0.2.2

An Elixir SDK for Claude Code - build AI-powered CLI tools with Claude.

HexDocs

Current section

Files

Jump to
Readme
41 Versions
2 Dependencies
Dependants
Files
Activity
claude_agent_sdk lib claude_agent_sdk streaming termination.ex
Raw

lib/claude_agent_sdk/streaming/termination.ex 

defmodule ClaudeAgentSDK.Streaming.Termination do

  @moduledoc """

  Shared termination logic for streaming sessions.



  Tracks stop_reason updates and determines when a message should complete.

  """



  @type stop_reason :: String.t() | nil



  @spec step(map(), stop_reason()) :: {stop_reason(), boolean()}

  def step(event, current_reason) do

    new_reason =

      case event do

        %{type: :message_start} ->

          nil



        %{type: :message_delta, stop_reason: reason} when not is_nil(reason) ->

          reason



        _ ->

          current_reason

      end



    complete? =

      case event do

        %{type: :message_stop} ->

          new_reason != "tool_use"



        _ ->

          false

      end



    {new_reason, complete?}

  end



  @spec reduce([map()], stop_reason()) :: {stop_reason(), boolean()}

  def reduce(events, current_reason) when is_list(events) do

    Enum.reduce(events, {current_reason, false}, fn event, {reason, complete?} ->

      {next_reason, event_complete?} = step(event, reason)

      {next_reason, complete? or event_complete?}

    end)

  end

end