You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The iterable will be treated differently, in that instead of being converted to an Observable and firehosing out nexts, it will get an iterator and next() once, waiting for the other Observables to emit.. as soon as the zip emits, the iterator will next() once more, and so on.
Each time the iterator.next() is called, the IteratorResult will be examined to see if it's done, if it's done, it will flag itself as no longer active and the Observable will end
The text was updated successfully, but these errors were encountered:
So the idea is this (I'll use
Observable.zip
as an example):Assume:
The
iterable
will be treated differently, in that instead of being converted to an Observable and firehosing out nexts, it will get aniterator
andnext()
once, waiting for the other Observables to emit.. as soon as thezip
emits, theiterator
willnext()
once more, and so on.Each time the
iterator.next()
is called, theIteratorResult
will be examined to see if it'sdone
, if it'sdone
, it will flag itself as no longeractive
and the Observable will endThe text was updated successfully, but these errors were encountered: