shaclapi.multiprocessing.PipeAdapter module#

class shaclapi.multiprocessing.PipeAdapter.ConnectionAdapter(connection, is_sender)[source]#

Bases: object

The idea is to use a Connection Object with the functions of a Queue.

put(item)[source]#

get(block=True, timeout=None)[source]#

class shaclapi.multiprocessing.PipeAdapter.PipeAdapter[source]#: Bases: object

class shaclapi.multiprocessing.PipeAdapter.QueueAdapter(context)[source]#: Bases: object