Stream

The Stream module contains the classes Stream and BlockStream.

class streaming.stream.Stream(iterator)[source]

Bases: streaming.abstractstream.AbstractStream

Stream of samples.

drop(nsamples)[source]

Drop the first n samples.

take(nsamples)[source]

Take the first nsamples samples.

class streaming.stream.BlockStream(iterator, nblock, noverlap=0)[source]

Bases: streaming.abstractstream.AbstractStream

Stream of blocks of samples.

drop(n)[source]

Drop the first n blocks.

Note

If you want to drop n samples, use s.samples().drop(n).

map(func)[source]

Map func to each block in BlockStream.

mean()[source]

Mean value calculated over nblock samples.

This function returns a Stream.

nblocks()[source]

Amount of blocks in stream.

Warning

This consumes the stream.

samples()[source]

Iterate over samples.

Returns:Stream of samples insteads of blocks. Possible overlap is taking into account.
std()[source]

Standard deviation calculated over nblock samples.

This function returns a Stream.

sum()[source]

Sum calculated over nblock samples.

This function returns a Stream.

take(nblocks)[source]

Take nblocks from stream.

var()[source]

Variance calculated over nblock samples.

This function returns a Stream.

streaming.stream.count(start=0, step=1)[source]

Count.