Backplane.McpProtocol.Transport.StreamableHTTP.Stream (backplane_mcp_protocol v0.6.0)

Copy Markdown

Owns one modern request-scoped POST/SSE exchange.

A small controller remains responsive to owner, transport, and explicit close signals while a linked worker blocks in Finch. The worker carries an incremental SSE frame buffer so arbitrary TCP chunk boundaries never become protocol message boundaries.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

close(pid, timeout \\ 5000)
start(opts)

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

close(pid, timeout \\ 5000)

@spec close(pid(), timeout()) :: :ok | {:error, term()}

start(opts)

@spec start(map()) :: GenServer.on_start()