Fork me on GitHub
#aleph
<
2018-02-27
>
lxsameer11:02:14

So basically in a stream pipeline from the beginning to the end I'll be in the same thread unless i use a feature which move the execution flow to another thread, or i have to manually use onto to move the execution flow

mccraigmccraig11:02:05

i'm not sure @lxsameer - most of my processing involves some async i/o and so moves to other threads anyway, so i've never bothered to investigate

lxsameer11:02:52

how do you force it to move to the blocking thread ? do you use blocking queues ?

mccraigmccraig11:02:49

uh, some misunderstanding i think - i don't do any blocking - i have async i/o ops which return Deferred values

lxsameer11:02:25

ow shoot, my bad