Package Anomos :: Module PartialMessageQueue :: Class PartialMessageQueue

Class PartialMessageQueue

object --+
         |
        PartialMessageQueue

Instance Methods

[hide private]

__init__(self)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature

source code

queue_message(self, sid, message)
Add a message to the message queue

source code

is_partial(self, message)

source code

mk_partial(self, message)

source code

dequeue_partial(self, sid, numbytes)
Dequeue numbytes from the message queue.

source code

remove_by_sid(self, sid)
Removes all messages queued by the stream given by sid

source code

_pindex(self, sid, p)

source code

__len__(self)

source code

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self)
(Constructor)

source code

x.__init__(...) initializes x; see x.__class__.__doc__ for signature

Overrides: object.__init__: (inherited documentation)

queue_message(self, sid, message)

source code

Add a message to the message queue

Parameters:

streamid (int) - Stream ID of message sender
message (string) - Message to be sent

dequeue_partial(self, sid, numbytes)

source code

Dequeue numbytes from the message queue. Return the stream IDs associated with the messages which were dequeued in full and the message to be sent.

Parameters:

numbytes (int) - Number of bytes to be sent

Returns:

([Stream IDs...], "Message")

Class PartialMessageQueue

__init__(self) (Constructor)

queue_message(self, sid, message)

dequeue_partial(self, sid, numbytes)

init(self)
(Constructor)