scala-streams

0зной

1ответ

Как преобразовать источник Akka в scala.stream

У меня уже есть Source[T], но мне нужно передать его функции, которая требует Stream[T]. Я мог бы .run источник и материализовать все в список, а затем сделать результат .toStream, но который удаляет

scala akka-stream scala-streams 2017-01-16

---

4зной

1ответ

Scala как получить последнее расчетное значение потока?

В соответствии с потоком scala docs реализуются ленивые списки, где элементы оцениваются только тогда, когда они необходимы. Пример; val fibs: Stream[BigInt] = BigInt(0) #:: BigInt(1) #:: fibs.zip(fib

scala stream lazy-evaluation memoization scala-streams 2017-01-26

---

0зной

1ответ

Первого элемента Ленивого потока в Scala

Вот минимальный пример, я могу определить функцию, которая дает мое следующее целое через def nextInteger(input: Int): Int = input+1 то я могу определить ленивый поток целых чисел, как lazy val inte

scala functional-programming stream lazy-evaluation scala-streams 2016-08-31

---

0зной

1ответ

Реализация chopBy в потоках Akka

Отвечая this question, Odomontois показал, как вы можете реализовать ленивый групповой оператор, который может группировать предварительно отсортированный поток с помощью ключа без необходимости храни

scala akka akka-stream scala-streams 2016-09-01

---

3зной

2ответ

Как внезапно остановить поток akka Runnable Graph?

Я не могу понять, как немедленно остановить поток akka Runnable Graph? Как использовать killswitch для достижения этого? Прошло всего несколько дней, когда я начал аккские потоки. В моем случае я чита

scala io akka akka-stream scala-streams 2016-08-03

---