Abstract Streams
The module streaming.abtractstream contains an abstract base class for streams.
Furthermore, additional signatures are added to allow the operators defined in streaming.operators to work with class:`streaming.abstractstream.AbstractStream.
-
class
streaming.abstractstream.AbstractStream(iterator)[source]
Bases: collections.abc.Iterator
Abstract stream.
-
blocks()[source]
Stream with blocks.
-
copy()[source]
Make a copy of the stream.
-
cos()[source]
Cosine.
-
cycle()[source]
Cycle the stream.
-
drop(n)[source]
Drop the first n items.
-
exp()[source]
Exponential.
-
map(func)[source]
Map func to each sample in Stream.
-
nblock
Amount of samples per block.
-
nsamples()[source]
Amount of samples in stream.
Warning
This consumes the stream.
-
peek()[source]
Check the first item in the stream.
-
repeat_each(n)[source]
Repeat each item n times before yielding the next.
-
samples()[source]
Stream with samples.
-
sin()[source]
Sine.
-
sqrt()[source]
Square root.
-
take(n)[source]
Take the first n.
-
take_nth(n)[source]
Take every `n`th.
-
tan()[source]
Tangens.
-
tee(n=2)[source]
Split stream in n streams.
-
toarray()[source]
Convert to array.