API

Basic API Interface

pystreaming.Streamer	Video streamer with P2P and Map-Reduce functionality.
pystreaming.Worker	Worker in the Map-Reduce streaming pattern.
pystreaming.Receiver	Receiver frames from a video stream.

Internal API Interface

pystreaming.video.collect.CollectDevice(…)	Create a collection device.
pystreaming.video.enc.EncoderDevice(nproc, seed)	Create a multiprocessing frame encoder device.
pystreaming.video.dec.DecoderDevice(nproc, seed)	Create a multiprocessing frame decoder device.
pystreaming.video.dist.DistributorDevice(…)	Create a multiprocessing frame distributor device.
pystreaming.video.req.RequesterDevice(…)	Create a asyncio frame requester device.
pystreaming.video.pub.PublisherDevice(…)	Create a publisher device.
pystreaming.video.sub.SubscriberDevice(…)	Create a multiprocessing subscriber.
pystreaming.listlib.circularlist.CircularList([…])	Initialize a Circular List with maximum size.
pystreaming.listlib.circulardict.CircularOrderedDict(maxsize)	A dictionary that never exceeds a given size.