Port-based streaming for long-running Docker commands.

A BEAM-native extension not present in the Rust crate. Useful for docker logs --follow, docker events, docker build, etc.

Lines are sent as messages to the subscriber process:

{:docker_stream, pid, {:stdout, line}}
{:docker_stream, pid, {:exit, exit_code}}

Examples

# Stream logs from a container
{:ok, stream} = Docker.Stream.start_link(
  Docker.Commands.Logs.new("my-container") |> Docker.Commands.Logs.follow(),
  subscriber: self()
)

receive do
  {:docker_stream, ^stream, {:stdout, line}} ->
    IO.puts("LOG: #{line}")
  {:docker_stream, ^stream, {:exit, 0}} ->
    IO.puts("Stream ended")
end

# Stop streaming
Docker.Stream.stop(stream)

Options

• :subscriber - PID to receive stream messages (required)
• :config - Docker.Config to use (default: Docker.Config.new())