Здравствуйте, _NN_, Вы писали:
_NN>Мне нужно вычислить сколько раз я его получал с тем же именем, либо по прошествию таймаута если не было никаких событий.
ПО описанию до конца задачу не понял, но очень похоже на стандартный Buffer(). Стандартный — в смысле, что его почти везде используют.
Если ещё не прочитана, очень рекомендую intro to Rx.
Вот глава про time-shifted.