code: func NewStream(reader io.Reader, writer io.Writer, maxWriteDelay time.Duration) *Stream {
  	return &Stream{
  		Decoder: NewDecoder(reader),
  		Encoder: NewEncoder(writer, maxWriteDelay),
  	}
  }
docs: // NewStream creates a new Stream.