// CloseRecv implements transport.Receiver.CloseRecv.
CloseRecv implements transport.Receiver.CloseRecv.
// CloseRecv implements transport . Receiver . CloseRecv .
func (c *ConnectedEndpoint) CloseRecv() {
	c.mu.Lock()
	defer c.mu.Unlock()
	if err := unix.Shutdown(c.fd, unix.SHUT_RD); err != nil {
		panic(fmt.Sprintf("failed read shutdown on host socket %+v: %v", c, err))
	}
}
func ( c * ConnectedEndpoint ) CloseRecv ( ) { c . mu . Lock ( ) defer c . mu . Unlock ( ) if err := unix . Shutdown ( c . fd , unix . SHUT_RD ) ; err != nil { panic ( fmt . Sprintf ( " " , c , err ) ) } }
CloseRecv implements transport.Receiver.CloseRecv.
CloseRecv implements transport . Receiver . CloseRecv .
// A well-formed UDS shutdown can't fail. See // net/unix/af_unix.c:unix_shutdown.