void Crupier::onSync( ) noexcept {
    LOG_DEBUG( ) << "Procesando tareas pendientes";

    auto limit = m_readyToUploadQueue.size( );
    for( Unsigned idx = 0; idx < limit; ++idx ) {
        auto work = m_readyToUploadQueue.front( );
        m_readyToUploadQueue.pop( );

        assert( work );
        assert( work->crupier( ) );
        auto baseClient = work->baseClient( );
        assert( baseClient );

        if( !baseClient->userData( ) ) {
            // El cliente fue cancelado.
            --idx;

[I] Crupier.cpp:28 Iniciando Crupier, 12 workers, cola de uploads listos: 24
[I] NetManager.cpp:25 Iniciando NetManager, puerto 8080
[I] NetManager.cpp:35 Iniciando bucle de eventos
[I] Client.cpp:53 0x56056f18bbf0 Establecida conexi?n
[I] Crupier.cpp:130 [127.0.0.1:59488] Autorizado UPLOAD
[I] Crupier.cpp:108 [127.0.0.1:59488] Iniciando trabajo
[I] Crupier.cpp:86 [127.0.0.1:59488] Enviando respuesta OK 1000
[I] NetManager.cpp:70 Cliente [ 127.0.0.1:59488 ] ha cerrado la conexi?n

SERVER = ( '127.0.0.1', 8080 )

def generanteRandomData( ):
    Mega = 1024 * 1024
    size = random.randint( Mega, Mega * 10 )
    data = bytes( size )

    return ( size, '/UNA/RUTA/ABSOLUTA/CUALQUIERA', data )


async def readData( reader: asyncio.StreamReader, seps = 1 ) -> bytes:
    buffer = bytearray( )

    while True:
        readed = await reader.read( 1 )
        buffer += readed
        if buffer[-1:] == b'\00': break

    return buffer[:-1]

async def uploadData( reader, writer, data ):

Enviando <1996935/UNA/RUTA/ABSOLUTA/CUALQUIERA>
Mensaje enviado
Recibido OK, subiendo datos
Enviando datos
Datos enviados

candid@gear:~/PycharmProjects/upload$ python test.py 5
Enviando <8274681/UNA/RUTA/ABSOLUTA/CUALQUIERA>
Mensaje enviado
Enviando <10399072/UNA/RUTA/ABSOLUTA/CUALQUIERA>
Mensaje enviado
Enviando <9649473/UNA/RUTA/ABSOLUTA/CUALQUIERA>
Mensaje enviado
Enviando <9602436/UNA/RUTA/ABSOLUTA/CUALQUIERA>
Mensaje enviado
[OK]
Cerrando conexion
[OK]
Cerrando conexion
[OK]
Cerrando conexion
[OK]
Cerrando conexion

bool HeaderInteractor::execute( std::string_view data ) noexcept {
    if( ( m_buffer.size( ) + data.size( ) ) > HEADER_BUFFER_SIZE ) {
        LOG_ERROR( ) << "Datos de Hello demasiado grandes";

        m_error = Error::BAD_HEADER;
        return false;
    }

    m_buffer.insert( m_buffer.end( ), data.cbegin( ), data.cend( ) );

    if( !m_first.has_value( ) ) {
        auto iter = std::find( m_buffer.cbegin( ), m_buffer.cend( ), ZERO );

        if( iter == m_buffer.cend( ) ) {
            return true;