Home       Trees       Index       Help   
Package twisted :: Package protocols :: Module pcp :: Class ProducerConsumerProxy
[show private | hide private]
[frames | no frames]

Class ProducerConsumerProxy

BasicProducerConsumerProxy --+
                             |
                            ProducerConsumerProxy

Known Subclasses:
ShapedConsumer

ProducerConsumerProxy with a finite buffer.

When my buffer fills up, I have my parent Producer pause until my buffer has room in it again.
Method Summary
  __init__(self, consumer)
(inherited from BasicProducerConsumerProxy)
  __repr__(self)
(inherited from BasicProducerConsumerProxy)
  finish(self)
(inherited from BasicProducerConsumerProxy)
  pauseProducing(self)
  registerProducer(self, producer, streaming)
  resumeProducing(self)
  stopProducing(self)
(inherited from BasicProducerConsumerProxy)
  unregisterProducer(self)
  write(self, data)
  _writeSomeData(self, data)
Write as much of this data as possible.

Class Variable Summary
int bufferSize
int producerPaused
int unregistered

Method Details

_writeSomeData(self, data)

Write as much of this data as possible.
Returns:
The number of bytes written.

Class Variable Details

bufferSize

Type:
int
Value:
65536

producerPaused

Type:
int
Value:
0

unregistered

Type:
int
Value:
0

   Home       Trees       Index       Help   
Generated by Epydoc 1.1 on Fri Jun 27 03:48:36 2003 http://epydoc.sf.net