jacinle.comm.distrib.pipe#

Classes

`DistribBroadcastPipeBase`
`DistribInputPipe`
`DistribOutputPipe`
`PipeBase`

Class DistribBroadcastPipeBase

class DistribBroadcastPipeBase[source]#

Bases: PipeBase

__init__(direction, name, bufsize=10)[source]#

__new__(**kwargs)#

empty()#

full()#

get()#

get_nowait()#

put(data)#

put_nowait(data)#

set_controller(controller)#

property controller#

property direction#

property identifier#

property name#

property raw_queue#

Class DistribInputPipe

class DistribInputPipe[source]#

Bases: DistribBroadcastPipeBase

__init__(name, bufsize=10)[source]#

__new__(**kwargs)#

empty()#

full()#

get()#

get_nowait()#

put(data)#

put_nowait(data)#

set_controller(controller)#

property controller#

property direction#

property identifier#

property name#

property raw_queue#

Class DistribOutputPipe

class DistribOutputPipe[source]#

Bases: DistribBroadcastPipeBase

__init__(name, bufsize=10)[source]#

__new__(**kwargs)#

empty()#

full()#

get()#

get_nowait()#

put(data)#

put_nowait(data)#

set_controller(controller)#

property controller#

property direction#

property identifier#

property name#

property raw_queue#

Class PipeBase

class PipeBase[source]#

Bases: object

__init__(direction, name, bufsize, identifier=None)[source]#

__new__(**kwargs)#

empty()[source]#

full()[source]#

get()[source]#

get_nowait()[source]#

put(data)[source]#

put_nowait(data)[source]#

set_controller(controller)[source]#

property controller#

property direction#

property identifier#

property name#

property raw_queue#