class ShapedTransport(ShapedConsumer): (source)
Wraps a Transport and shapes the rate at which it receives data.
This is a ShapedConsumer
with a little bit of magic to provide for the case where the consumer it wraps is also a Transport and people will be attempting to access attributes this does not proxy as a Consumer (e.g. loseConnection).
Method | __getattr__ |
Undocumented |
Class Variable | iAmStreaming |
Undocumented |
Inherited from ShapedConsumer
:
Method | __init__ |
Undocumented |
Method | stopProducing |
Stop producing data. |
Instance Variable | bucket |
Undocumented |
Method | _writeSomeData |
Write as much of this data as possible. |
Inherited from ProducerConsumerProxy
(via ShapedConsumer
):
Method | pauseProducing |
Undocumented |
Method | registerProducer |
Register to receive data from a producer. |
Method | resumeProducing |
Undocumented |
Method | unregisterProducer |
Stop consuming data from a producer, without disconnecting. |
Method | write |
The producer will write data by calling this method. |
Class Variable | bufferSize |
Undocumented |
Instance Variable | outstandingPull |
Undocumented |
Instance Variable | paused |
Undocumented |
Instance Variable | producerPaused |
Undocumented |
Instance Variable | unregistered |
Undocumented |
Inherited from BasicProducerConsumerProxy
(via ShapedConsumer
, ProducerConsumerProxy
):
Method | __repr__ |
Undocumented |
Method | finish |
Undocumented |
Class Variable | stopped |
Undocumented |
Instance Variable | consumer |
the Consumer I publish to. |
Instance Variable | producer |
the Producer I subscribe to. |
Instance Variable | producerIsStreaming |
Undocumented |
Instance Variable | _buffer |
Undocumented |