ストリームデータ処理について

解決したいこと

ストリーミングデータ処理について

時間とともにほぼ無限に増えるデータにたいして1行分の値を保持し、その値に対応する値がでるまでのデータを読み捨てていきその値がでたときに相応の処理をする。
というものを無限ループ処理を利用して作りたいのですがどういった方法が適切ですか？

Rubyで行う予定です