> Am 02.09.2017 um 04:45 schrieb Xingcan Cui <[email protected]>:
>
> In your codes, all the the long values will subtract 1 and be sent back to
> the iterate operator, endlessly.
Is this true? shouldn't
val iterationResult2 = env.generateSequence(1, 4).iterate(it => {
(it.filter(_ > 0).map(_ - 1), it.filter(_ > 0).map(_ => 'y')) // dump
meaningless 'y' chars just to do anything
})
iterationResult2.print()
produce the following _feedback_ streams?
initial input to #iterate(): [1 2 3 4]
iteration #1 : [1 2 3]
iteration #2 : [1 2]
iteration #3 : [1]
iteration #4 : [] => empty feedback stream => cause termination? (which
actually only happens when setting a timeout value)
Best regards
Peter
