Lines Matching defs:Pipe
13 // Pipe creates a synchronous, in-memory, full duplex
18 func Pipe() (Conn, Conn) {
19 r1, w1 := io.Pipe()
20 r2, w2 := io.Pipe()
22 return &pipe{r1, w2}, &pipe{r2, w1}
25 type pipe struct {
33 return "pipe"
37 return "pipe"
40 func (p *pipe) Close() error {
49 func (p *pipe) LocalAddr() Addr {
53 func (p *pipe) RemoteAddr() Addr {
57 func (p *pipe) SetDeadline(t time.Time) error {
58 return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
61 func (p *pipe) SetReadDeadline(t time.Time) error {
62 return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
65 func (p *pipe) SetWriteDeadline(t time.Time) error {
66 return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
