// kqueue-based 'wait for events' system call
    int avail = kevent(queueFD, nullptr, 0, rawEvents, TRIGGERED_SET_SIZE,  tvalp);
    
    if(avail < 0)
    {
        // error handling
    }

    VectorMap<SocketHandler, SocketEvent<T_SOCKET>> triggered;
    
    for(int iEvent = 0; iEvent < avail; ++iEvent)
    {
        SocketHandler  handler = rawEvents[iEvent].ident;  // kqueue based implementation to obtain socket descriptor
        
        if(handler == ancillaryReadFD)
        {
            // listening socket close handling (pipe-trick)

                        ...

            // sockhdlr is a listening socket descriptor that was closed
            // socket is a pointer to correnponding socket class instance
            SocketEvent<T_SOCKET>  &event  = triggered.GetAdd(sockhdlr, SocketEvent<T_SOCKET>(socket));
            event.SetTriggeredException();
            
            continue;
        }
        
        T_SOCKET *socket  = socketHandler.Get(handler, nullptr);  //socketHandler is VectorMap<SOCKET, *SOCKET_T>
        
        // if socket was removed after ancillaryReadFD data was delivered
        // pipe-trick implementation to track listening socket closing
        if(!socket)
            continue;
        
        SocketEvent<T_SOCKET>  &event  = triggered.GetAdd(handler, SocketEvent<T_SOCKET>(socket));
        
        if(rawEvents[iEvent].flags & (EV_EOF | EV_ERROR))
            event.SetTriggeredException();
        
        if(rawEvents[iEvent].filter == EVFILT_READ)
            event.SetTriggeredRead();
        
        if(rawEvents[iEvent].filter == EVFILT_WRITE)
            event.SetTriggeredWrite();
    }
    
    return pick(triggered.GetValues());