У меня уже есть Source[T], но мне нужно передать его функции, которая требует Stream[T]. Я мог бы .run источник и материализовать все в список, а затем сделать результат .toStream, но который удаляет
Вот минимальный пример, я могу определить функцию, которая дает мое следующее целое через def nextInteger(input: Int): Int = input+1
то я могу определить ленивый поток целых чисел, как lazy val inte
Отвечая this question, Odomontois показал, как вы можете реализовать ленивый групповой оператор, который может группировать предварительно отсортированный поток с помощью ключа без необходимости храни
Я не могу понять, как немедленно остановить поток akka Runnable Graph? Как использовать killswitch для достижения этого? Прошло всего несколько дней, когда я начал аккские потоки. В моем случае я чита