code: func (l *logdogServer) AddStream(rc io.ReadCloser, props *streamproto.Properties) error {
  	return l.butler.AddStream(rc, props)
  }
docs: // AddStream adds a new stream.
  // If no error is returned, the logdogServ assumes ownership of the supplied
  // stream. The stream will be closed when processing is finished.