>>625
ありがとうございます。unsafeInterleaveIOは面白い関数ですね。

ただ、今回は到着したデータを直ちに出力をしなければなりません。
groupByによる出力をする作りだと、
次のレコードが到着するまで最終的な出力がされません。
たとえば、以下のようなタイミングでデータが到着するとします。
>1秒目: a(改行)b(改行)c
>3秒目: d(改行)e(改行)

groupByを使った作りの場合、ファイル.1秒目にデータが出力されるタイミングは
3秒目の最初の改行が届いた後になってしまいます。
2秒目になった後に直ちに書き込みをしたいとおもっています。



今は色々調べていたらtimeout関数という物を見つけたので、
こいつを参考に書いてみれば良いのかと思い試行錯誤しています。
他に何かあったらよろしくお願いします。