twistedutil.protocol.GreenTransport: allow write_event be customized
This commit is contained in:
@@ -78,10 +78,10 @@ class GreenTransportBase(object):
|
|||||||
if self.transportBufferSize is not None:
|
if self.transportBufferSize is not None:
|
||||||
transport.bufferSize = self.transportBufferSize
|
transport.bufferSize = self.transportBufferSize
|
||||||
self.init_transport_producer(transport)
|
self.init_transport_producer(transport)
|
||||||
ev = event()
|
if self.write_event is None:
|
||||||
ev.send(1)
|
self.write_event = event()
|
||||||
transport.registerProducer(Producer2Event(ev), True)
|
self.write_event.send(1)
|
||||||
self.write_event = ev
|
transport.registerProducer(Producer2Event(self.write_event), True)
|
||||||
self.transport = transport
|
self.transport = transport
|
||||||
|
|
||||||
class Protocol(twistedProtocol):
|
class Protocol(twistedProtocol):
|
||||||
|
Reference in New Issue
Block a user