// RecvMaxQueueSize implements transport.Receiver.RecvMaxQueueSize.
RecvMaxQueueSize implements transport.Receiver.RecvMaxQueueSize.
// RecvMaxQueueSize implements transport . Receiver . RecvMaxQueueSize .
func (c *ConnectedEndpoint) RecvMaxQueueSize() int64 {
	return atomic.LoadInt64(&c.sndbuf)
}
func ( c * ConnectedEndpoint ) RecvMaxQueueSize ( ) int64 { return atomic . LoadInt64 ( & c . sndbuf ) }
RecvMaxQueueSize implements transport.Receiver.RecvMaxQueueSize.
RecvMaxQueueSize implements transport . Receiver . RecvMaxQueueSize .
// N.B. Unix sockets don't use the receive buffer. We'll claim it is // the same size as the send buffer.