λ
Size: a a a
λ
AS
λ
AS
IZ
monix
. как в такой непростой ситуации https://scalafiddle.io/sf/hgpm4dr/1 остановить mainPipeline так, чтобы Await внизу сработал? В текущем варианте Await не видит завершения и висит вечно. Суть вообще такая: крутится таска, выпуская какие-то данные, как только новое значение получено запускается другая таска, которая его обрабатывает. Параллельно с ней первая таска выпускает новый элемент и тогда отменяет предыдущую таску и запускает новую с новым значением. и вот если во внутренней таске происходит эксепшен какой-то, он вообще везде игнорится. основной пайплайн продолжает работать. Если выполнить только innerPipelineTask.cancel()
, то mainPipeline имеет возможность выпустить новый элемент и только потом увидит, что внутренняя таска завершилась и сам завершится. воть. хотелось бы убрать холостой прогон основной таски после завершения внутренней.h
𝛈µ
𝛈µ
𝛈µ
d
d
AS
scala.Seq
и прочие, теперь они иммутабельные коллекции алиасят.d
h
h
𝛈µ
𝛈µ
𝛈µ
𝛈µ
h