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).
| Class Variable | iAmStreaming |
Undocumented |
| Method | __getattr__ |
Undocumented |
Inherited from ShapedConsumer:
| Method | __init__ |
Undocumented |
| Instance Variable | bucket |
Undocumented |
| Method | stopProducing |
Stop producing data. |
| Method | _writeSomeData |
Write as much of this data as possible. |
Inherited from ProducerConsumerProxy (via ShapedConsumer):
| Class Variable | bufferSize |
Undocumented |
| Instance Variable | producerPaused |
Undocumented |
| Instance Variable | unregistered |
Undocumented |
| Method | pauseProducing |
Undocumented |
| Instance Variable | paused |
Undocumented |
| Method | resumeProducing |
Undocumented |
| Instance Variable | outstandingPull |
Undocumented |
| Method | write |
The producer will write data by calling this method. |
| Method | registerProducer |
Register to receive data from a producer. |
| Method | unregisterProducer |
Stop consuming data from a producer, without disconnecting. |
Inherited from BasicProducerConsumerProxy (via ShapedConsumer, ProducerConsumerProxy):
| Instance Variable | producer |
the Producer I subscribe to. |
| Instance Variable | consumer |
the Consumer I publish to. |
| Instance Variable | producerIsStreaming |
Undocumented |
| Class Variable | stopped |
Undocumented |
| Method | finish |
Undocumented |
| Method | __repr__ |
Undocumented |
| Instance Variable | _buffer |
Undocumented |