Nie blokująca linii rubla czytaj

Question

Próbuję odczytać linię z IO w sposób nieblokujący.

Niestety bloki readline. Myślę, że mogę rozwiązać ten problem z read_nonblock z dodatkowym buforem, w którym przechowuję wynik częściowy, sprawdzam, czy w buforze jest wiele linii, itd., Ale wydaje się to nieco skomplikowane w przypadku prostego zadania takiego jak to. Czy jest lepszy sposób to zrobić?

Uwaga: Używam demultipleksowanie zdarzeń (select) i jestem bardzo z niego zadowolony, nie chcę tworzyć tematy, użyj EventMachine, etc ...

Answer 1

myślę, że jest rozwiązanie read_nonblock prawdopodobnie droga. Proste, nie maksymalnie wydajna wersja monkey-patch:

class IO 
    def readline_nonblock 
    rlnb_buffer = "" 
    while ch = self.read_nonblock(1) 
     rlnb_buffer << ch 
     if ch == "\n" then 
     result = rlnb_buffer 
     return result 
     end 
    end  
    end 
end  

To zgłasza wyjątek, jeśli nie jest gotowy Brak danych, podobnie jak read_nonblock, więc trzeba ratować, że po prostu uzyskać nil powrotem itd

Answer 2

ta implementacja poprawia odpowiedź Mark Reeda przez nie odrzucając odczytu danych, który nie kończy się znakiem nowej linii:

class IO 
    def readline_nonblock 
    buffer = "" 
    buffer << read_nonblock(1) while buffer[-1] != "\n" 

    buffer 
    rescue IO::WaitReadable => blocking 
    raise blocking if buffer.empty? 

    buffer 
    end 
end