Method get

internal/transport/transport.go:125–127

get returns the channel that receives a recvMsg in the buffer. Upon receipt of a recvMsg, the caller should call load to send another recvMsg onto the channel if there is any.

()

// Upon receipt of a recvMsg, the caller should call load to send another
// recvMsg onto the channel if there is any.
func (b *recvBuffer) get() <-chan recvMsg {
	return b.c
}

// recvBufferReader implements io.Reader interface to read the data from
// recvBuffer.