Home
last modified time | relevance | path

Searched refs:_consumer (Results 1 – 25 of 123) sorted by relevance

12345

/dports/math/frobby/frobby-0.9.1/src/
H A DIrreducibleIdealSplitter.cpp25 _consumer(consumer), in IrreducibleIdealSplitter()
31 _consumer(*consumer), in IrreducibleIdealSplitter()
39 _consumer.consumeRing(names); in consumeRing()
48 _consumer.beginConsumingList(); in beginConsumingList()
60 _consumer.beginConsuming(); in consume()
64 _consumer.consume(_tmp); in consume()
68 _consumer.doneConsuming(); in consume()
78 _consumer.beginConsuming(); in consume()
86 _consumer.doneConsuming(); in consume()
95 _consumer.beginConsuming(); in consume()
[all …]
H A DTranslatingTermConsumer.cpp27 _consumer(consumer) { in TranslatingTermConsumer()
33 _consumer(*consumer) { in TranslatingTermConsumer()
39 _consumer.beginConsumingList(); in beginConsumingList()
43 _consumer.consumeRing(names); in consumeRing()
47 _consumer.beginConsuming(); in beginConsuming()
53 _consumer.consume(term, _translator); in consume()
57 _consumer.consume(term); in consume()
62 _consumer.consume(term, translator); in consume()
66 _consumer.doneConsuming(); in doneConsuming()
70 _consumer.doneConsumingList(); in doneConsumingList()
[all …]
H A DTranslatingCoefTermConsumer.cpp27 _consumer(consumer) { in TranslatingCoefTermConsumer()
33 _consumer(*consumer), in TranslatingCoefTermConsumer()
39 _consumer.beginConsuming(); in beginConsuming()
43 _consumer.consumeRing(names); in consumeRing()
48 _consumer.consume(coef, term, translator); in consume()
53 _consumer.consume(coef, term); in consume()
59 _consumer.consume(coef, term, _translator); in consume()
63 _consumer.doneConsuming(); in doneConsuming()
67 _consumer.consume(poly); in consume()
H A DHilbertSlice.cpp26 _consumer(0) { in HilbertSlice()
33 _consumer(consumer) { in HilbertSlice()
38 ASSERT(_consumer != 0); in baseCase()
60 _consumer->consume(coef, getMultiply()); in baseCase()
69 _consumer = ((HilbertSlice&)slice)._consumer; in operator =()
87 _consumer = consumer; in setToProjOf()
92 std::swap(_consumer, slice._consumer); in swap()
H A DMsmSlice.cpp25 _consumer(0) { in MsmSlice()
34 _consumer(consumer) { in MsmSlice()
41 ASSERT(_consumer != 0); in baseCase()
59 _consumer->consume(_multiply); in baseCase()
110 _consumer->consume(_multiply); in baseCase()
118 _consumer = ((MsmSlice&)slice)._consumer; in operator =()
140 _consumer = consumer; in setToProjOf()
167 std::swap(_consumer, slice._consumer); in swap()
275 _consumer->consume(_lcm); in twoVarBaseCase()
395 _consumer->consume(tmp); in twoNonMaxBaseCase()
[all …]
H A DCanonicalCoefTermConsumer.cpp24 _consumer(consumer) { in CanonicalCoefTermConsumer()
25 ASSERT(_consumer.get() != 0); in CanonicalCoefTermConsumer()
46 _consumer->consumeRing(_names); in doneConsuming()
47 _consumer->beginConsuming(); in doneConsuming()
49 _consumer->consume(_polynomial.getCoef(index), _polynomial.getTerm(index)); in doneConsuming()
50 _consumer->doneConsuming(); in doneConsuming()
H A DCanonicalTermConsumer.cpp31 _consumer(consumer), in CanonicalTermConsumer()
33 ASSERT(_consumer.get() != 0); in CanonicalTermConsumer()
37 _consumer->consumeRing(names); in consumeRing()
86 _consumer->beginConsumingList(); in doneConsumingList()
89 _consumer->doneConsumingList(); in doneConsumingList()
101 _consumer->beginConsuming(); in passLastIdeal()
106 _consumer->consume(tmp); in passLastIdeal()
110 _consumer->doneConsuming(); in passLastIdeal()
H A Dfrobby.cpp67 _consumer(consumer) { in ExternalIdealConsumerWrapper()
68 ASSERT(_consumer != 0); in ExternalIdealConsumerWrapper()
84 _consumer->consume(_term); in consume()
91 _consumer->consume(_term); in consume()
95 _consumer->idealEnd(); in doneConsuming()
108 _consumer(consumer), in ExternalPolynomialConsumerWrapper()
145 _consumer->polynomialEnd(); in doneConsuming()
325 _consumer(consumer), in IrreducibleIdealDecoder()
327 ASSERT(_consumer != 0); in IrreducibleIdealDecoder()
357 _consumer->idealEnd(); in consume()
[all …]
H A DIdealConsolidator.cpp24 _consumer(consumer), in IdealConsolidator()
32 _consumer->consumeRing(names); in consumeRing()
43 _consumer->beginConsumingList(); in beginConsumingList()
80 _consumer->consume(_ideal); in doneConsuming()
87 _consumer->doneConsumingList(); in doneConsumingList()
91 _consumer->consume(ideal); in consume()
H A DMsmStrategy.cpp31 _consumer(consumer), in MsmStrategy()
40 _consumer(consumer), in MsmStrategy()
49 _consumer->beginConsuming(); in run()
59 (new MsmSlice(*this, ideal, *_initialSubtract, sliceMultiply, _consumer)); in run()
65 _consumer->doneConsuming(); in run()
202 _consumer = consumer; in reset()
233 _consumer->consume(_tmpTerm); in consume()
251 TermConsumer* _consumer; member in MsmIndependenceSplit
H A DPolynomialConsolidator.cpp22 _consumer(consumer) { in PolynomialConsolidator()
46 _consumer->consume(_poly); in doneConsuming()
51 _consumer->consume(poly); in consume()
H A DTotalDegreeCoefTermConsumer.cpp27 _consumer(*consumer), in TotalDegreeCoefTermConsumer()
36 _consumer(consumer), in TotalDegreeCoefTermConsumer()
63 _poly.feedTo(_consumer, true); in doneConsuming()
/dports/www/tikiwiki/tiki-21.2/vendor_bundled/vendor/laminas/laminas-oauth/library/Laminas/OAuth/Http/
H A DAccessToken.php50 'oauth_consumer_key' => $this->_consumer->getConsumerKey(),
52 'oauth_signature_method' => $this->_consumer->getSignatureMethod(),
54 'oauth_token' => $this->_consumer->getLastRequestToken()->getToken(),
55 'oauth_version' => $this->_consumer->getVersion(),
64 $this->_consumer->getSignatureMethod(),
65 $this->_consumer->getConsumerSecret(),
66 $this->_consumer->getLastRequestToken()->getTokenSecret(),
68 $this->_consumer->getAccessTokenUrl()
87 $client->setUri($this->_consumer->getAccessTokenUrl());
105 $client->setUri($this->_consumer->getAccessTokenUrl());
H A DRequestToken.php50 'oauth_consumer_key' => $this->_consumer->getConsumerKey(),
53 'oauth_signature_method' => $this->_consumer->getSignatureMethod(),
54 'oauth_version' => $this->_consumer->getVersion(),
58 if ($this->_consumer->getCallbackUrl()) {
59 $params['oauth_callback'] = $this->_consumer->getCallbackUrl();
70 $this->_consumer->getSignatureMethod(),
71 $this->_consumer->getConsumerSecret(),
74 $this->_consumer->getRequestTokenUrl()
95 $client->setUri($this->_consumer->getRequestTokenUrl());
119 $client->setUri($this->_consumer->getRequestTokenUrl());
H A DUserAuthorization.php29 $uri = Uri\UriFactory::factory($this->_consumer->getUserAuthorizationUrl());
46 'oauth_token' => $this->_consumer->getLastRequestToken()->getToken(),
50 $callback = $this->_consumer->getCallbackUrl();
/dports/www/chromium-legacy/chromium-88.0.4324.182/ios/chrome/browser/ui/overlays/infobar_modal/passwords/
H A Dpassword_infobar_modal_overlay_mediator.mm40 if (_consumer == consumer)
43 _consumer = consumer;
46 if (!_consumer || !config)
49 [_consumer setUsername:config->username()];
51 [_consumer setMaskedPassword:[@"" stringByPaddingToLength:password.length
54 [_consumer setUnmaskedPassword:password];
55 [_consumer setDetailsTextMessage:config->details_text()];
56 [_consumer setSaveButtonText:config->save_button_text()];
57 [_consumer setCancelButtonText:config->cancel_button_text()];
58 [_consumer setURL:config->url()];
[all …]
/dports/devel/py-celery/celery-4.4.7/celery/backends/
H A Drpc.py46 _consumer = None variable in ResultConsumer
55 self._consumer = self.Consumer(
59 self._consumer.consume()
69 self._consumer.cancel()
74 self._consumer = None
80 if self._consumer is None:
83 if not self._consumer.consuming_from(queue):
84 self._consumer.add_queue(queue)
85 self._consumer.consume()
88 if self._consumer:
[all …]
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/lib_rpl/rpl/
H A Dmap.h24 : _consumer(consumer) in map_transform_helper()
32 _consumer.put_next_forward( in operator()
40 _consumer.put_next_forward( in operator()
45 consumer<NewValue, Error, Handlers> _consumer;
133 , _consumer(consumer) { in map_error_transform_helper()
140 _consumer.put_error_forward( in operator()
148 _consumer.put_error_forward( in operator()
153 consumer<Value, NewError, Handlers> _consumer;
H A Dmerge.h26 : _consumer(consumer) in merge_subscribe_one()
32 _consumer.add_lifetime(std::move(producer).start( in subscribe()
33 [consumer = _consumer](auto &&value) { in subscribe()
36 }, [consumer = _consumer](auto &&error) { in subscribe()
39 }, [consumer = _consumer, state = _state] { in subscribe()
47 const consumer_type &_consumer;
/dports/textproc/py-python-lsp-jsonrpc/python-lsp-jsonrpc-1.0.0/pylsp_jsonrpc/
H A Dendpoint.py32 self._consumer = consumer
58 self._consumer(message)
85 self._consumer(message)
119 self._consumer({
126 self._consumer({
198 self._consumer({
227 self._consumer(message)
/dports/devel/py-python-jsonrpc-server/python-jsonrpc-server-0.4.0/pyls_jsonrpc/
H A Dendpoint.py29 self._consumer = consumer
55 self._consumer(message)
82 self._consumer(message)
116 self._consumer({
123 self._consumer({
195 self._consumer({
224 self._consumer(message)
/dports/www/tikiwiki/tiki-21.2/vendor_bundled/vendor/laminas/laminas-oauth/library/Laminas/OAuth/
H A DHttp.php30 protected $_consumer = null; variable in Laminas\\OAuth\\Http
68 $this->_consumer = $consumer;
69 $this->_preferredRequestScheme = $this->_consumer->getRequestScheme();
135 return $this->_consumer;
267 $this->_consumer->getRequestTokenUrl());
/dports/www/chromium-legacy/chromium-88.0.4324.182/ios/chrome/browser/ui/overlays/web_content_area/alerts/
H A Dalert_overlay_mediator.mm38 if (_consumer == consumer)
40 _consumer = consumer;
49 [_consumer setTitle:alertRequest->title()];
50 [_consumer setMessage:alertRequest->message()];
51 [_consumer setTextFieldConfigurations:alertRequest->text_field_configs()];
54 [_consumer setActions:alertActions];
55 [_consumer
/dports/devel/py-pika/pika-1.1.0/examples/
H A Dasyncio_consumer_example.py406 self._consumer = ExampleConsumer(self._amqp_url)
411 self._consumer.run()
413 self._consumer.stop()
418 if self._consumer.should_reconnect:
419 self._consumer.stop()
423 self._consumer = ExampleConsumer(self._amqp_url)
426 if self._consumer.was_consuming:
H A Dasynchronous_consumer_example.py402 self._consumer = ExampleConsumer(self._amqp_url)
407 self._consumer.run()
409 self._consumer.stop()
414 if self._consumer.should_reconnect:
415 self._consumer.stop()
419 self._consumer = ExampleConsumer(self._amqp_url)
422 if self._consumer.was_consuming:

12345