code: func NewBufferedStream(conn io.ReadWriteCloser, codec ObjectCodec) ObjectStream {
  	return &bufferedObjectStream{
  		conn:  conn,
  		w:     bufio.NewWriter(conn),
  		r:     bufio.NewReader(conn),
  		codec: codec,
  	}
  }
docs: // NewBufferedStream creates a buffered stream from a network
  // connection (or other similar interface). The underlying
  // objectStream is used to produce the bytes to write to the stream
  // for the JSON-RPC 2.0 objects.