Plushie.Transport.IOStream (Plushie v0.7.0)

Copy Markdown View Source

Transport implementation for iostream adapter connections.

Communicates with an external process that owns the underlying I/O (SSH channel, TCP socket, WebSocket, etc.). The adapter process handles framing and delivers complete protocol messages.

Protocol:

  1. Bridge sends {:iostream_bridge, bridge_pid} during init.
  2. Adapter sends {:iostream_data, binary} for incoming data.
  3. Bridge sends {:iostream_send, iodata} for outgoing data.
  4. Adapter sends {:iostream_closed, reason} on transport close.

Summary

Types

t()

@type t() :: %Plushie.Transport.IOStream{
  alive: boolean(),
  io_pid: pid(),
  monitor_ref: reference()
}