dspex

# Generated by SnakeBridge v0.12.0 - DO NOT EDIT MANUALLY
# Regenerate with: mix compile
# Library: dspy 3.1.2
# Python module: dspy.streaming.messages

defmodule Dspy.Streaming.Messages do
  @moduledoc """
  Submodule bindings for `dspy.streaming.messages`.
  """

  def __snakebridge_python_name__, do: "dspy.streaming.messages"
  def __snakebridge_library__, do: "dspy"

  @doc """
  Send message to stream in a sync context, regardless of event loop state.

  Parameters:
  - `stream` (term())
  - `message` (term())

  Returns:
  - `term()`
  """
  @spec sync_send_to_stream(term(), term(), keyword()) ::
          {:ok, term()} | {:error, Snakepit.Error.t()}
  def sync_send_to_stream(stream, message, opts \\ []) do
    SnakeBridge.Runtime.call(__MODULE__, :sync_send_to_stream, [stream, message], opts)
  end
end