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
right ?
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
how do you force it to move to the blocking thread ? do you use blocking queues ?
uh, some misunderstanding i think - i don't do any blocking - i have async i/o ops which return Deferred values
ow shoot, my bad
thanks man