Така че вземам Head и започвам да обработвам. Проблем, ако това трябва да се мащабира и да се използва услуга за изпълнение на 8 нишки за модул/екземпляр, при внезапно изключване на системата „съобщенията“ биха се считали за взети/изконсумирани вече.
Вместо това трябва да използвате обект RStream, който позволява проследяване на неизползвани елементи на потребител.
