code: func (m *Streamer) Stream(stdout, stderr chan []byte) StreamID {
  	sid := m.idGen.next()
  	m.streams.Store(sid, newStream(stdout, stderr))
  
  	return sid
  }
docs: // Stream sets up streaming for the given pair of channels and returns a StreamID to identify the pair.
  // The caller must call Stop to avoid leaking memory.