Function pipe

master/buildbot/test/integration/worker/test_proxy.py:52–59

(reader, writer)

async def handle_client(local_reader, local_writer):
    async def pipe(reader, writer):
        try:
            while not reader.at_eof():
                writer.write(await reader.read(2048))
        except ConnectionResetError:
            pass
        finally:
            writer.close()

    try:
        request = await local_reader.read(2048)