pystreaming.audio package

Submodules

pystreaming.audio.patterns module

class pystreaming.audio.patterns.AudioReceiver(endpoint)[source]

Bases: object

Audio receiver.

Connects using a zmq SUB socket.

Parameters

endpoint (str) – Descriptor of stream publishing endpoint.

handler(timeout=0)[source]

Yield a package of data from audio channel.

Parameters

timeout (int, optional) – Timeout period in milliseconds. Defaults to 0.

Yields

dict – Expected items, with keys: {arr, meta, ftime, fno}.

recv(timeout)[source]

Receive a package of data from the audio channel.

Parameters

timeout (int) – Timeout period in milliseconds.

Raises

TimeoutError – Raised when no messages are received in the timeout period.

class pystreaming.audio.patterns.AudioStreamer(endpoint)[source]

Bases: object

Audio streamer.

Binds to a zmq PUB socket.

Parameters

endpoint (str) – Descriptor of stream publishing endpoint.

send(arr)[source]

Send a buffer of audio.

Parameters

arr (np.ndarray) – A segment of audio as a numpy array.

pystreaming.audio.tape module

class pystreaming.audio.tape.Tape(length)[source]

Bases: object

read(left, right)[source]
write(data)[source]

Module contents