zero.Stream.set_loader¶

Stream.set_loader(loader)[source]¶

Set new loader.

Parameters: loader (Iterable) –
Raises: AssertionError – if loader is not an iterator and is empty.
Return type: None

Examples

from itertools import repeat
stream = Stream(repeat(0))
for x in stream.data(5):
    print(stream.iteration, x)
    if stream.iteration == 2:
        stream.set_loader(repeat(1))