Lines Matching refs:Pipeline
11 // A Pipeline manages a pipelined in-order request/response sequence.
13 // To use a Pipeline p to manage multiple clients on a connection,
20 // p.EndRequest(id) // notify Pipeline that request is sent
24 // p.EndResponse(id) // notify Pipeline that response is read
28 type Pipeline struct {
36 func (p *Pipeline) Next() uint {
46 func (p *Pipeline) StartRequest(id uint) {
52 func (p *Pipeline) EndRequest(id uint) {
58 func (p *Pipeline) StartResponse(id uint) {
64 func (p *Pipeline) EndResponse(id uint) {
