Harshavardhana <******@****.***> 1679380686 -0700

Harshavardhana <******@****.***> 1721351702 -0700

Shinsuke Sugaya <******@****.***> 1379138428 +0900

Ian Lance Taylor <******@****.***> 1645759397 -0800

Adam Murdoch <******@****.***> 1713920984 +1000

Mihai Maruseac <******@****.***> 1696518010 -0700

	dst   chan []jstream.KVS // result of block decode
	err   error              // any error encountered will be set here
}

// Read - reads single record.
// Once Read is called the previous record should no longer be referenced.
func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
	// If we have have any records left, return these before any error.
	for len(r.current) <= r.recordsRead {
		if r.err != nil {

}

// disconnectReader will ensure that no reads can take place on
// the upstream reader after close has been called.
type disconnectReader struct {
	r  io.Reader
	mu sync.Mutex
}

func (d *disconnectReader) Read(p []byte) (n int, err error) {
	d.mu.Lock()
	defer d.mu.Unlock()
	if d.r != nil {
		return d.r.Read(p)
	}
	return 0, errors.New("reader closed")
}

Brad Fitzpatrick <******@****.***> 1306186071 -0700

Dmitri Shuralyov <******@****.***> 1721666689 -0400