scala-streams

0熱

1答えて

私はすでにSource[T]を持っていますが、それはStream[T]を必要とする関数に渡す必要があります。私は.runソースを取得してリストにすべてをマテリアライズし、結果に.toStreamを実行しますが、保持したいレイジー/ストリームのアスペクトを削除します。これを行うにはこれが唯一の方法ですか、何か不足していますか？ EDIT：ウラジミールさんのコメントを読んだ後、私は私が間違った方

1熱

2答えて

forEachのは期待：消費者[_>：パス]実際：（パス）=>ブール

間違った構文の問題を再帰的に削除Scalaのファイル Files.walk(path, FileVisitOption.FOLLOW_LINKS) .sorted(Comparator.reverseOrder()) .forEach(Files.deleteIfExists)

1熱

1答えて

Scalaのストリーム反復処理し、メモリ管理

私はこのコードを持っている： val res = Stream // launch the real computation, which alternates E and M steps, updating the computation state .iterate(initCompState)(Base.emIteration) .take(nIteration)

4熱

1答えて

スカラストリームの最後の計算値を取得する方法は？

scala docs streamによると、エレメントは必要なときにのみ評価されるレイジーリストを実装します。例。 val fibs: Stream[BigInt] = BigInt(0) #:: BigInt(1) #:: fibs.zip(fibs.tail).map(n => { n._1 + n._2 }) その後、scala repl; fibs(4) fibs 出

0熱

1答えて

Akka StreamsでchopByを実装する

Answer this question Odomontoisは、あらかじめソートされたストリームをキーでグループ化できるレイジーグループバイ演算子を、メモリにすべて格納することなくグループ化する方法を示しました。 Akkaのストリーム（つまりソースオブジェクト）でこれを行う方法はありますか？代わりに、Akmaソースから通常のStreamオブジェクトを引き出す方法があるので、私はOdomontoi

0熱

1答えて

Scalaワークシートはこのコードでは機能しません。コンパイルエラーは表示されません

Eclipseでscalaワークシートで何かを試しています。これは出力を表示していないため、エラーまたは警告も表示されません。 object stream { println("Welcome to the Scala worksheet") def cons[T](hd: T, t1: => Stream[T]): Stream[T] = new Stream[T] {

3熱

2答えて

akkaストリームを突然停止する方法Runnable Graph？

akkaストリームRunnableグラフを直ちに停止する方法を理解できませんか？これを達成するためにkillswitchを使用するには？私がアクアストリームを始めたのはほんの数日でした。私の場合、私はファイルから行を読み込み、流し込みやシンクへの書き込みでいくつかの操作をしています。私がしたいことは、いつでもファイルをすぐに読むことをやめて、実行中のグラフ全体を停止させる必要があると思います。これ