(*channels, **kwargs)
return a, b
Create a new full duplex Pipe

    Returns a pair of UNIXClient instances connected on either side of
    the pipe.
Create a new full duplex Pipe
Create a new full duplex Pipe
def Pipe(*channels, **kwargs):
    """Create a new full duplex Pipe

    Returns a pair of UNIXClient instances connected on either side of
    the pipe.
    """

    from socket import socketpair

    if not channels:
        channels = ("a", "b")

    s1, s2 = socketpair()
    s1.setblocking(False)
    s2.setblocking(False)

    a = UNIXClient(s1, channel=channels[0], **kwargs)
    b = UNIXClient(s2, channel=channels[1], **kwargs)

    a._connected = True
    b._connected = True

    return a, b
def Pipe ( * channels , * * kwargs ) : from socket import socketpair if not channels : channels = ( "a" , "b" ) s1 , s2 = socketpair ( ) s1 . setblocking ( False ) s2 . setblocking ( False ) a = UNIXClient ( s1 , channel = channels [ 0 ] , * * kwargs ) b = UNIXClient ( s2 , channel = channels [ 1 ] , * * kwargs ) a . _connected = True b . _connected = True return a , b