Пацаны, вот так говно?: class A[T] { @volatile private var

Question

Пацаны, вот так говно?: class A[T] { @volatile private var

started = true

def start = {
val source: Source[T, NotUsed] = ???
source.mapAsync(...)(...).takeWhile(_ => started).runWith(...)
}

def stop() = {
started = false
}
}
Можно или лучше через киллсвитч?

#programming #russian #scala

0

28.02.2018

4 ответов

15 просмотров

Python

Оберните в GraphStage, а доступ к started предоставляйте через materialized value. Будет очень классный код.

0

28.02.2018

Ale Sha

+1 за KillSwitch

0

28.02.2018

Oleg ℕižnik

перед тем, как оно у тебя увидит, что takeWhile стало false, оно после stop успеет запустить ещё батч футурок в mapAsync

0

28.02.2018

Vladimir Sam · Accepted Answer

Vladimir Sam

может как-то можно с генератор-функцией обыграть () => Source[Whatever]

0

28.02.2018

169 похожих чатов

Пацаны, вот так говно?: class A[T] { @volatile private var

4 ответов

Похожие вопросы