def on_channel_read(self, handle, data, pending, error):
    if (self.tcp_server is None):
        self.assertEqual(pending, pyuv.UV_TCP)
        self.tcp_server = pyuv.TCP(self.loop)
        self.channel.accept(self.tcp_server)
        self.tcp_server.listen(self.on_ipc_connection, 12)
        self.assertEqual(data.strip(), b'hello')
        self.channel.write(b'world')
        self.make_many_connections()
    elif (data.strip() == b'accepted_connection'):
        self.assertEqual(pending, pyuv.UV_UNKNOWN_HANDLE)
        self.channel.close()
def on_channel_read(self, handle, data, pending, error):
    if (self.tcp_server is None):
        self.assertEqual(pending, pyuv.UV_TCP)
        self.tcp_server = pyuv.TCP(self.loop)
        self.channel.accept(self.tcp_server)
        self.tcp_server.listen(self.on_ipc_connection, 12)
        self.assertEqual(data.strip(), b'hello')
        self.channel.write(b'world')
        self.make_many_connections()
    elif (data.strip() == b'accepted_connection'):
        self.assertEqual(pending, pyuv.UV_UNKNOWN_HANDLE)
        self.channel.close()