[Scala] Stream の転送はこのようにして。

前回 は Stream オブジェクトをリモートアクターに転送するにはどうすればいいか？という話でした。 せっかく Straem を使うわけですから。List に変換したり、転送時に Stream を foreach で走査して、再構築するなんて事はしないで。値の評価の遅延だけでなく、プロセス間のデータ転送まで遅延したいところです。 という事で。Stream のデータ転送を遅延する、抽象化機構を作ってみました。 この Stream を抽象化するデータ構造を AStream とここでは名づけます [*1]。 まず。リモートアクターに Stream 転送する際、直接 Stream を送らないで別のデータ構造に変換してからリモートに転送するようにします。 そこで、入力に Stream オブジェクトを取る set メソッドを作り、出力に入力した Stream に可換な別のデータ構造を吐き出すようにし