/dports/www/py-treq/treq-20.9.0/src/treq/test/ |
H A D | test_multipart.py | 56 producer.startProducing(consumer) 153 complete = producer.startProducing(consumer) 188 producer.startProducing(consumer) 215 complete = producer.startProducing(BytesIO()) 240 complete = producer.startProducing(consumer) 263 complete = producer.startProducing(consumer) 298 producer.startProducing(consumer)
|
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/channels/test/ |
H A D | ChannelTest.cpp | 263 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_P() 275 producer_->startProducing(std::move(sender), std::runtime_error("Error")); in TEST_P() 287 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_P() 301 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_P() 316 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_P()
|
H A D | MergeTest.cpp | 220 producer->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 241 producers_.at(i)->startProducing( in TEST_F() 268 producers_.at(i)->startProducing( in TEST_F() 288 producers_.at(i)->startProducing( in TEST_F() 313 producers_.at(i)->startProducing( in TEST_F()
|
H A D | MergeChannelTest.cpp | 520 producers_.at(0)->startProducing(std::move(sender0), std::nullopt); in TEST_F() 526 producers_.at(1)->startProducing(std::move(sender1), std::nullopt); in TEST_F() 546 producers_.at(0)->startProducing(std::move(sender0), std::nullopt); in TEST_F() 552 producers_.at(1)->startProducing(std::move(sender1), std::nullopt); in TEST_F() 572 producers_.at(0)->startProducing(std::move(sender0), std::nullopt); in TEST_F() 578 producers_.at(1)->startProducing(std::move(sender1), std::nullopt); in TEST_F() 601 producers_.at(0)->startProducing(std::move(sender0), std::nullopt); in TEST_F() 607 producers_.at(1)->startProducing(std::move(sender1), std::nullopt); in TEST_F()
|
H A D | TransformTest.cpp | 443 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 461 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 479 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 501 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 956 newProducer->startProducing( in TEST_F() 1006 newProducer->startProducing( in TEST_F()
|
H A D | FanoutChannelTest.cpp | 319 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F() 347 producer_->startProducing(std::move(sender), std::nullopt /* closeEx */); in TEST_F()
|
H A D | ChannelTestUtil.h | 234 void startProducing( in startProducing() function
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/contrib/cmdclient/ |
H A D | http.py | 185 def startProducing(self, consumer): member in _RawProducer 204 def startProducing(self, consumer): member in _JsonProducer
|
/dports/devel/py-twisted/Twisted-22.1.0/docs/web/howto/listings/client/ |
H A D | bytesprod.py | 13 def startProducing(self, consumer): member in BytesProducer
|
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/spread/ |
H A D | util.py | 163 self.startProducing(fd) 165 def startProducing(self, fd): member in FilePager
|
/dports/math/vtk6/VTK-6.2.0/ThirdParty/Twisted/twisted/spread/ |
H A D | util.py | 161 self.startProducing(fd) 163 def startProducing(self, fd): member in FilePager
|
/dports/www/py-treq/treq-20.9.0/src/treq/ |
H A D | multipart.py | 68 def startProducing(self, consumer): member in MultiPartProducer 210 d = producer.startProducing(consumer)
|
H A D | testing.py | 205 def startProducing(self, consumer): member in _SynchronousProducer
|
/dports/math/vtk6/VTK-6.2.0/ThirdParty/Twisted/twisted/web/ |
H A D | iweb.py | 434 def startProducing(consumer): member in IBodyProducer
|
H A D | _newclient.py | 654 d = self.bodyProducer.startProducing(encoder) 692 finishedProducing = self.bodyProducer.startProducing(encoder)
|
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/web/ |
H A D | iweb.py | 486 def startProducing(consumer): member in IBodyProducer
|
H A D | _newclient.py | 762 d = self.bodyProducer.startProducing(encoder) 806 finishedProducing = self.bodyProducer.startProducing(encoder)
|
/dports/www/py-spyne/spyne-2.13.16/spyne/client/twisted/ |
H A D | __init__.py | 65 def startProducing(self, consumer): member in _Producer
|
/dports/dns/py-ns1-python/ns1-python-0.16.0/ns1/rest/transport/ |
H A D | twisted.py | 72 def startProducing(self, consumer): member in StringProducer
|
/dports/math/vtk6/VTK-6.2.0/ThirdParty/Twisted/twisted/web/test/ |
H A D | test_agent.py | 180 complete = producer.startProducing(consumer) 198 producer.startProducing(consumer) 215 complete = producer.startProducing(FileConsumer(StringIO())) 234 complete = producer.startProducing(consumer) 253 complete = producer.startProducing(consumer) 282 producer.startProducing(consumer)
|
H A D | test_newclient.py | 1689 def startProducing(consumer): function 1693 producer.startProducing = startProducing 1744 def startProducing(self, consumer): member in StringProducer
|
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/web/test/ |
H A D | test_agent.py | 226 complete = producer.startProducing(consumer) 243 producer.startProducing(consumer) 261 complete = producer.startProducing(FileConsumer(BytesIO())) 276 complete = producer.startProducing(consumer) 296 complete = producer.startProducing(consumer) 313 complete = producer.startProducing(consumer) 340 producer.startProducing(consumer) 359 complete = producer.startProducing(consumer)
|
H A D | test_newclient.py | 1845 def startProducing(consumer): function 1850 producer.startProducing = startProducing 1897 def startProducing(self, consumer): member in StringProducer
|
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/test/integration/ |
H A D | test_telegram_bot.py | 49 def startProducing(self, consumer): member in BytesProducer
|
/dports/security/cowrie/cowrie-2.2.0/src/cowrie/output/ |
H A D | virustotal.py | 422 def startProducing(self, consumer): member in StringProducer
|