def METHOD_NAME(request):
    from moler.io.raw.memory import ThreadedFifoBuffer
    from moler.threaded_moler_connection import ThreadedMolerConnection
    moler_conn = ThreadedMolerConnection(decoder=lambda data: data.decode("utf-8"))
    connection = ThreadedFifoBuffer(moler_connection=moler_conn)
    return connection