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.