Axon.experimental._pprocess_support.likefile

For examples and more explanations, see the module level docs.

class likefile(object)

Methods defined here

__del__(self)

__init__(self, child[, extraInboxes][, extraOutboxes][, wrapDefault])

anyReady(self)

empty(self[, boxname])

Return True if there is no data pending collection on boxname, False otherwise.

get(self[, boxname][, blocking][, timeout])

Performs a blocking read on the queue corresponding to the named outbox on the wrapped component. raises AttributeError if the likefile is not alive. Optional parameters blocking and timeout function the same way as in Queue objects, since that is what's used under the surface.

get_nowait(self[, boxname])

Equivalent to get(boxname, False)

put(self, msg[, boxname])

Places an object on a queue which will be directed to a named inbox on the wrapped component.

qsize(self[, boxname])

Returns the approximate number of pending data items awaiting collection from boxname. Will never be smaller than the actual amount.

shutdown(self)

Sends terminatory signals to the wrapped component, and shut down the componentWrapper. will warn if the shutdown took too long to confirm in action.