/dports/databases/py-sqlalchemy11/SQLAlchemy-1.1.18/test/orm/ |
H A D | test_deferred.py | 3 from sqlalchemy.orm import mapper, deferred, defer, undefer, Load, \ 23 'description': deferred(orders.c.description)}) 51 'id': deferred(orders.c.id)}) 67 'description': deferred(orders.c.description)}) 94 'description': deferred(orders.c.description)}) 141 'description': deferred(orders.c.description)}) 518 ('lower_desc', deferred( 552 ('userident', deferred(orders.c.user_id)), 554 ('opened', deferred(orders.c.isopen)) 624 description=deferred(items.c.description))) [all …]
|
/dports/net/jcifs/jcifs_1.3.19/src/jcifs/dcerpc/msrpc/ |
H A D | srvsvc.java | 23 _dst = _dst.deferred; in encode() 33 _src = _src.deferred; in decode() 50 _dst = _dst.deferred; in encode() 68 _src = _src.deferred; in decode() 100 _dst = _dst.deferred; in encode() 105 _dst = _dst.deferred; in encode() 117 _src = _src.deferred; in decode() 122 _src = _src.deferred; in decode() 139 _dst = _dst.deferred; in encode() 157 _src = _src.deferred; in decode() [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Data.Linq/src/DbLinq/Data/Linq/ |
H A D | EntitySet.cs | 51 private bool deferred; field in System.Data.Linq.EntitySet 132 deferred = false; in GetEnumerator() 227 deferred = false; in IndexOf() 241 deferred = false; in Insert() 254 deferred = false; in RemoveAt() 299 deferred = false; in Clear() 321 deferred = false; in Contains() 332 deferred = false; in CopyTo() 369 deferred = false; in Remove() 530 deferred = true; in SetSource() [all …]
|
/dports/net-mgmt/icingaweb2-module-reactbundle/icingaweb2-module-reactbundle-0.9.0/vendor/clue/socks-react/src/ |
H A D | StreamReader.php | 73 $deferred = new Deferred(); 75 $this->readBufferCallback(function (&$buffer) use ($bytes, $deferred) { 77 $deferred->resolve((string)substr($buffer, 0, $bytes)); 84 return $deferred->promise(); 108 $deferred = new Deferred(); 112 $readOne = function () use (&$readOne, $that, $deferred, &$string) { 113 $that->readByte()->then(function ($byte) use ($deferred, &$string, $readOne) { 115 $deferred->resolve($string); 124 return $deferred->promise();
|
/dports/devel/R-cran-pkgcache/pkgcache/tests/async/ |
H A D | test-deferred.R | 6 dx1 <- deferred$new(~ resolve(TRUE))$ 9 dx2 <- deferred$new(~ stop("oops"))$ 12 dx3 <- deferred$new(~ if (TRUE) resolve(TRUE) else stop("oops"))$ 15 dx4 <- deferred$new(~ if (FALSE) resolve(TRUE) else stop("oops"))$ 25 dx1 <- deferred$new(~resolve(TRUE))$ 29 dx2 <- deferred$new(~resolve(TRUE))$ 33 dx3 <- deferred$new(~resolve(TRUE))$ 60 d1 <- deferred$new( 62 d2 <- deferred$new(
|
/dports/databases/py-sqlalchemy10/SQLAlchemy-1.0.14/test/orm/ |
H A D | test_deferred.py | 3 from sqlalchemy.orm import mapper, deferred, defer, undefer, Load, \ 23 'description': deferred(orders.c.description)}) 51 'id': deferred(orders.c.id)}) 69 'description': deferred(orders.c.description)}) 95 'description': deferred(orders.c.description)}) 140 'description': deferred(orders.c.description)}) 385 ('userident', deferred(orders.c.user_id)), 387 ('opened', deferred(orders.c.isopen)) 409 'description': deferred(orders.c.description)}) 435 'description': deferred(orders.c.description)}) [all …]
|
/dports/math/vtk6/VTK-6.2.0/ThirdParty/Twisted/twisted/web/ |
H A D | xmlrpc.py | 398 deferred = None variable in _QueryFactory 427 if not self.deferred: 433 deferred, self.deferred = self.deferred, None 436 deferred, self.deferred = self.deferred, None 437 deferred.callback(response) 440 if self.deferred is not None: 441 deferred, self.deferred = self.deferred, None 442 deferred.errback(reason) 447 deferred, self.deferred = self.deferred, None 550 factory.deferred = None [all …]
|
/dports/www/py-spyne/spyne-2.13.16/spyne/server/twisted/ |
H A D | _base.py | 29 deferred = None variable in Producer 44 self.deferred = Deferred() 54 if self.deferred is not None: 55 self.deferred.callback(self.consumer) 56 self.deferred = None 65 if self.deferred is not None: 66 self.deferred.errback( 68 self.deferred = None
|
/dports/devel/amqp-cpp/AMQP-CPP-4.1.4/src/ |
H A D | channelimpl.cpp | 150 return *deferred; in push() 436 push(deferred); in purgeQueue() 439 return *deferred; in purgeQueue() 469 push(deferred); in removeQueue() 472 return *deferred; in removeQueue() 583 push(deferred); in consume() 586 return *deferred; in consume() 615 push(deferred); in cancel() 618 return *deferred; in cancel() 662 push(deferred); in get() [all …]
|
/dports/databases/redisdesktopmanager/RedisDesktopManager-2021.8/3rdparty/qredisclient/3rdparty/asyncfuture/tests/asyncfutureunittests/ |
H A D | spec.cpp | 20 auto o = deferred<T>(); in finishedFuture() 94 auto defer = deferred<int>(); in test_QFuture_isResultReadyAt() 318 auto d = deferred<int>(); in test_private_run() 434 auto d = deferred<void>(); in test_Observable_context() 719 auto o = deferred<int>(); in test_Observable_subscribe() 736 auto o = deferred<int>(); in test_Observable_subscribe() 1004 auto d1 = deferred<void>(); in test_Observable_onCanceled_deferred() 1005 auto d2 = deferred<void>(); in test_Observable_onCanceled_deferred() 1023 auto d1 = deferred<int>(); in test_Observable_onCanceled_future() 1024 auto d2 = deferred<int>(); in test_Observable_onCanceled_future() [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/executor/ |
H A D | connection_pool_asio_integration_test.cpp | 108 Deferred<RemoteCommandResponse> deferred; in TEST() local 115 [&deferred](RemoteCommandResponse resp) { deferred.emplace(std::move(resp)); }) in TEST() 118 ASSERT_OK(deferred.get().status); in TEST() 146 Deferred<RemoteCommandResponse> deferred; in TEST() local 154 ASSERT_OK(deferred.get().status); in TEST() 175 Deferred<RemoteCommandResponse> deferred; in TEST() local 213 for (auto& deferred : deferreds) { in TEST() local 220 for (auto& deferred : deferreds) { in TEST() local 221 ASSERT_EQ(deferred.get().isOK(), true); in TEST() 248 Deferred<RemoteCommandResponse> deferred; in TEST() local [all …]
|
H A D | network_interface_asio_test.cpp | 199 auto& result = deferred.get(); in TEST_F() 222 auto& result = deferred.get(); in TEST_F() 252 auto& result = deferred.get(); in TEST_F() 455 auto& res = deferred.get(); in TEST_F() 646 auto& res = deferred.get(); in TEST_F() 704 auto& res = deferred.get(); in TEST_F() 752 auto& res = deferred.get(); in TEST_F() 910 Deferred<Date_t> deferred; in TEST_F() local 968 auto& res = deferred.get(); in TEST_F() 997 auto& res = deferred.get(); in TEST_F() [all …]
|
/dports/net-mgmt/icingaweb2-module-reactbundle/icingaweb2-module-reactbundle-0.9.0/vendor/clue/buzz-react/src/Io/ |
H A D | Sender.php | 103 $deferred = new Deferred(function ($_, $reject) use ($requestStream) { 109 $requestStream->on('error', function($error) use ($deferred) { 110 $deferred->reject($error); 114 …$requestStream->on('response', function (ResponseStream $responseStream) use ($deferred, $messageF… 116 $deferred->resolve($messageFactory->response( 137 $body->on('close', $close = function () use ($deferred, $requestStream) { 138 …$deferred->reject(new \RuntimeException('Request failed because request body closed unexpectedly')… 141 $body->on('error', function ($e) use ($deferred, $requestStream, $close, $body) { 143 …$deferred->reject(new \RuntimeException('Request failed because request body reported an error', 0… 158 return $deferred->promise();
|
/dports/net-mgmt/icingaweb2-module-reactbundle/icingaweb2-module-reactbundle-0.9.0/vendor/react/http/src/Io/ |
H A D | Sender.php | 100 $deferred = new Deferred(function ($_, $reject) use ($requestStream) { 106 $requestStream->on('error', function($error) use ($deferred) { 107 $deferred->reject($error); 110 …, function (ResponseInterface $response, ReadableStreamInterface $body) use ($deferred, $request) { 121 $deferred->resolve($response->withBody(new ReadableBodyStream($body, $length))); 136 $body->on('close', $close = function () use ($deferred, $requestStream) { 137 …$deferred->reject(new \RuntimeException('Request failed because request body closed unexpectedly')… 140 $body->on('error', function ($e) use ($deferred, $requestStream, $close, $body) { 142 …$deferred->reject(new \RuntimeException('Request failed because request body reported an error', 0… 157 return $deferred->promise();
|
/dports/mail/nextcloud-mail/mail/vendor/amphp/byte-stream/lib/ |
H A D | IteratorStream.php | 40 $deferred = new Deferred; 42 $this->iterator->advance()->onResolve(function ($error, $hasNextElement) use ($deferred) { 47 $deferred->fail($error); 57 $deferred->fail($this->exception); 62 $deferred->resolve($chunk); 64 $deferred->resolve(); 68 return $deferred->promise();
|
H A D | ResourceOutputStream.php | 66 list($data, $previous, $deferred) = $writes->shift(); 70 $deferred->resolve(0); 122 $deferred->resolve($written + $previous); 129 $deferred->fail($exception); 131 list(, , $deferred) = $writes->shift(); 132 $deferred->fail($exception); 233 $deferred = new Deferred; 244 $this->writes->push([$data, $written, $deferred]); 246 $promise = $deferred->promise(); 291 list(, , $deferred) = $this->writes->shift(); [all …]
|
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/web/ |
H A D | xmlrpc.py | 406 deferred = None variable in QueryFactory 449 if not self.deferred: 454 deferred, self.deferred = self.deferred, None 457 deferred, self.deferred = self.deferred, None 458 deferred.callback(response) 461 if self.deferred is not None: 462 deferred, self.deferred = self.deferred, None 463 deferred.errback(reason) 468 deferred, self.deferred = self.deferred, None 588 factory.deferred = None [all …]
|
/dports/x11/nwg-dock/nwg-dock-0.2.2/vendor/github.com/joshuarubin/lifecycle/ |
H A D | lifecycle.go | 25 deferred []func() error member 43 deferred: []func() error{}, 107 func Defer(ctx context.Context, deferred ...func()) { 110 for _, t := range deferred { 112 m.deferred = append(m.deferred, wrapFunc(ctx, func() error { 123 func DeferErr(ctx context.Context, deferred ...func() error) { 126 for _, fn := range deferred { 127 m.deferred = append(m.deferred, wrapFunc(ctx, fn)) 236 for _, f := range m.deferred {
|
/dports/x11/nwg-drawer/nwg-drawer-0.2.8/vendor/github.com/joshuarubin/lifecycle/ |
H A D | lifecycle.go | 25 deferred []func() error member 43 deferred: []func() error{}, 107 func Defer(ctx context.Context, deferred ...func()) { 110 for _, t := range deferred { 112 m.deferred = append(m.deferred, wrapFunc(ctx, func() error { 123 func DeferErr(ctx context.Context, deferred ...func() error) { 126 for _, fn := range deferred { 127 m.deferred = append(m.deferred, wrapFunc(ctx, fn)) 236 for _, f := range m.deferred {
|
/dports/x11/nwg-menu/nwg-menu-0.1.1/vendor/github.com/joshuarubin/lifecycle/ |
H A D | lifecycle.go | 25 deferred []func() error member 43 deferred: []func() error{}, 107 func Defer(ctx context.Context, deferred ...func()) { 110 for _, t := range deferred { 112 m.deferred = append(m.deferred, wrapFunc(ctx, func() error { 123 func DeferErr(ctx context.Context, deferred ...func() error) { 126 for _, fn := range deferred { 127 m.deferred = append(m.deferred, wrapFunc(ctx, fn)) 236 for _, f := range m.deferred {
|
/dports/x11/nwg-bar/nwg-bar-0.0.1/vendor/github.com/joshuarubin/lifecycle/ |
H A D | lifecycle.go | 25 deferred []func() error member 43 deferred: []func() error{}, 107 func Defer(ctx context.Context, deferred ...func()) { 110 for _, t := range deferred { 112 m.deferred = append(m.deferred, wrapFunc(ctx, func() error { 123 func DeferErr(ctx context.Context, deferred ...func() error) { 126 for _, fn := range deferred { 127 m.deferred = append(m.deferred, wrapFunc(ctx, fn)) 236 for _, f := range m.deferred {
|
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/flang/test/Semantics/ |
H A D | resolve80.f90 | 17 procedure(subPublic), public, deferred, public :: publicBinding 19 procedure(subPrivate), private, deferred, private :: privateBinding 21 procedure(subDeferred), deferred, public, deferred :: deferredBinding 25 procedure(subNopass), nopass, deferred, nopass :: nopassBinding 27 procedure(subPass), pass, deferred, pass :: passBinding 29 procedure(subPassNopass), pass, deferred, nopass :: passNopassBinding
|
/dports/devel/wasi-libcxx/llvm-project-13.0.1.src/flang/test/Semantics/ |
H A D | resolve80.f90 | 18 procedure(subPublic), public, deferred, public :: publicBinding 20 procedure(subPrivate), private, deferred, private :: privateBinding 22 procedure(subDeferred), deferred, public, deferred :: deferredBinding 26 procedure(subNopass), nopass, deferred, nopass :: nopassBinding 28 procedure(subPass), pass, deferred, pass :: passBinding 30 procedure(subPassNopass), pass, deferred, nopass :: passNopassBinding ! C781
|
/dports/devel/llvm12/llvm-project-12.0.1.src/flang/test/Semantics/ |
H A D | resolve80.f90 | 17 procedure(subPublic), public, deferred, public :: publicBinding 19 procedure(subPrivate), private, deferred, private :: privateBinding 21 procedure(subDeferred), deferred, public, deferred :: deferredBinding 25 procedure(subNopass), nopass, deferred, nopass :: nopassBinding 27 procedure(subPass), pass, deferred, pass :: passBinding 29 procedure(subPassNopass), pass, deferred, nopass :: passNopassBinding ! C781
|
/dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/flang/test/Semantics/ |
H A D | resolve80.f90 | 17 procedure(subPublic), public, deferred, public :: publicBinding 19 procedure(subPrivate), private, deferred, private :: privateBinding 21 procedure(subDeferred), deferred, public, deferred :: deferredBinding 25 procedure(subNopass), nopass, deferred, nopass :: nopassBinding 27 procedure(subPass), pass, deferred, pass :: passBinding 29 procedure(subPassNopass), pass, deferred, nopass :: passNopassBinding ! C781
|