Знатокам fs2: есть стрим, сделанный из очереди stream.takeWhile().evalMap().compile.lastOrError, есть нужда

Question

Знатокам fs2: есть стрим, сделанный из очереди stream.takeWhile().evalMap().compile.lastOrError, есть нужда

по таймауту его прервать с ошибкой, если к данному моменту он ещё не завершился. interruptAfter просто прервет стрим, вернув последний на тот момент элемент (не то, нужно либо последний элемент при корректном завершении, либо ошибку). .timeout на результате F не остановит сам стрим. Единственный способ через interruptWhen и Deferred с Throwable? Или я что-то упустил

#programming #russian #scala

0

23.05.2019