ionelmc / python-remote-pdb

            wait_for_strings(proc.read, TIMEOUT, 'DIED.')

def test_redirect():

    with TestProcess(sys.executable, __file__, 'daemon', 'test_redirect') as proc:

        with dump_on_error(proc.read):

            wait_for_strings(proc.read, TIMEOUT,

                             '{a1}',

                             '{b1}',

                             'RemotePdb session open at ')

            host, port = re.findall("RemotePdb session open at (.+):(.+),", proc.read())[0]

            with TestSocket(socket.create_connection((host, int(port)), timeout=TIMEOUT)) as client:

                with dump_on_error(client.read):

                    wait_for_strings(proc.read, TIMEOUT, 'accepted connection from')

                    wait_for_strings(client.read, TIMEOUT, "-> print('{b2}')")

                    client.fh.write(b'break func_a\r\n')

                    client.fh.write(b'continue\r\n')

                    wait_for_strings(client.read, TIMEOUT, 'Breakpoint', '{b2}')

                    wait_for_strings(client.read, TIMEOUT, "-> print('{a2}')")

                    client.fh.write(b'continue\r\n')

                    wait_for_strings(client.read, TIMEOUT, "{=>")

            wait_for_strings(proc.read, TIMEOUT, 'DIED.')

            assert 'Restoring streams' not in proc.read()

def test_simple_break():

            assert 'Restoring streams' not in proc.read()

def test_simple_break():

    with TestProcess(sys.executable, __file__, 'daemon', 'test_simple') as proc:

        with dump_on_error(proc.read):

            wait_for_strings(proc.read, TIMEOUT,

                             '{a1}',

                             '{b1}',

                             'RemotePdb session open at ')

            host, port = re.findall("RemotePdb session open at (.+):(.+),", proc.read())[0]

            with TestSocket(socket.create_connection((host, int(port)), timeout=TIMEOUT)) as client:

                with dump_on_error(client.read):

                    wait_for_strings(proc.read, TIMEOUT, 'accepted connection from')

                    wait_for_strings(client.read, TIMEOUT, "-> print('{b2}')")

                    client.fh.write(b'break func_a\r\n')

                    client.fh.write(b'continue\r\n')

                    wait_for_strings(client.read, TIMEOUT, "-> print('{a2}')")

                    client.fh.write(b'continue\r\n')

            wait_for_strings(proc.read, TIMEOUT, 'DIED.')

            assert 'Restoring streams' not in proc.read()

def func_b(patch_stdstreams):