Streamer.WriteTo and Streamer.ReadFrom: helpers for stream plumbing with free synchronization.
Streamer.Shutdown: graceful shutdown of a job's streams after cleanly draining them.
Skeleton client implementation
Server.ServeConn: serves request on a single connection (eg. for in-memory command injection, testing..)