Home
last modified time | relevance | path

Searched refs:AsyncResult (Results 101 – 125 of 1316) sorted by relevance

12345678910>>...53

/dports/devel/glibmm/glibmm-2.64.2/gio/giomm/
H A Dinputstream.h291 Glib::RefPtr<Glib::Bytes> read_bytes_finish(const Glib::RefPtr<AsyncResult>& result);
427 gssize read_finish(const Glib::RefPtr<AsyncResult>& result);
516 bool read_all_finish(const Glib::RefPtr<AsyncResult>& result, gsize& bytes_read);
588 gssize skip_finish(const Glib::RefPtr<AsyncResult>& result);
631 gboolean close_finish(const Glib::RefPtr<AsyncResult>& result);
H A Dpermission.h177 bool acquire_finish(const Glib::RefPtr<AsyncResult>& result);
236 bool release_finish(const Glib::RefPtr<AsyncResult>& result);
315 virtual bool acquire_finish_vfunc(const Glib::RefPtr<AsyncResult>& result);
324 virtual bool release_finish_vfunc(const Glib::RefPtr<AsyncResult>& result);
H A Ddatainputstream.h344 bool read_line_finish(const Glib::RefPtr<AsyncResult>& result, std::string& data);
360 …void read_line_finish_utf8(const Glib::RefPtr<AsyncResult>& result, std::string& data, gsize& leng…
363 void read_line_finish_utf8(const Glib::RefPtr<AsyncResult>& result, std::string& data);
434 bool read_until_finish(const Glib::RefPtr<AsyncResult>& result, std::string& data);
490 bool read_upto_finish(const Glib::RefPtr<AsyncResult>& result, std::string& data);
H A Doutputstream.h418 gssize write_bytes_finish(const Glib::RefPtr<AsyncResult>& result);
588 gssize write_finish(const Glib::RefPtr<AsyncResult>& result);
690 bool write_all_finish(const Glib::RefPtr<AsyncResult>& result, gsize& bytes_written);
735 gssize splice_finish(const Glib::RefPtr<AsyncResult>& result);
766 bool flush_finish(const Glib::RefPtr<AsyncResult>& result);
803 bool close_finish(const Glib::RefPtr<AsyncResult>& result);
/dports/devel/php-ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/interrupt/
H A DAllTests.java19 import Ice.AsyncResult;
122 Ice.AsyncResult r = p.begin_op(); in allTests()
155 public void completed(AsyncResult r) in allTests()
222 Ice.AsyncResult r = p.begin_sleep(2000); in allTests()
269 Ice.AsyncResult r = p.begin_op(); in allTests()
292 Ice.AsyncResult r = p.begin_op(); in allTests()
337 Ice.AsyncResult r = null; in allTests()
380 AsyncResult r = p.begin_ice_getConnection(); in allTests()
426 AsyncResult r = p2.begin_ice_flushBatchRequests(); in allTests()
475 … AsyncResult r = p2.ice_getConnection().begin_flushBatchRequests(Ice.CompressBatch.BasedOnProxy); in allTests()
[all …]
/dports/devel/ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/interrupt/
H A DAllTests.java19 import Ice.AsyncResult;
122 Ice.AsyncResult r = p.begin_op(); in allTests()
155 public void completed(AsyncResult r) in allTests()
222 Ice.AsyncResult r = p.begin_sleep(2000); in allTests()
269 Ice.AsyncResult r = p.begin_op(); in allTests()
292 Ice.AsyncResult r = p.begin_op(); in allTests()
337 Ice.AsyncResult r = null; in allTests()
380 AsyncResult r = p.begin_ice_getConnection(); in allTests()
426 AsyncResult r = p2.begin_ice_flushBatchRequests(); in allTests()
475 … AsyncResult r = p2.ice_getConnection().begin_flushBatchRequests(Ice.CompressBatch.BasedOnProxy); in allTests()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/interrupt/
H A DAllTests.java19 import Ice.AsyncResult;
122 Ice.AsyncResult r = p.begin_op(); in allTests()
155 public void completed(AsyncResult r) in allTests()
222 Ice.AsyncResult r = p.begin_sleep(2000); in allTests()
269 Ice.AsyncResult r = p.begin_op(); in allTests()
292 Ice.AsyncResult r = p.begin_op(); in allTests()
337 Ice.AsyncResult r = null; in allTests()
380 AsyncResult r = p.begin_ice_getConnection(); in allTests()
426 AsyncResult r = p2.begin_ice_flushBatchRequests(); in allTests()
475 … AsyncResult r = p2.ice_getConnection().begin_flushBatchRequests(Ice.CompressBatch.BasedOnProxy); in allTests()
[all …]
/dports/java/springframework31/spring-framework-3.1.4.RELEASE/projects/org.springframework.aspects/src/test/java/org/springframework/scheduling/aspectj/
H A DAnnotationAsyncExecutionAspectTests.java30 import org.springframework.scheduling.annotation.AsyncResult;
170 return new AsyncResult<Integer>(5); in incrementReturningAFuture()
202 return new AsyncResult<Integer>(5); in incrementReturningAFuture()
210 return new AsyncResult<Thread>(Thread.currentThread()); in defaultWork()
215 return new AsyncResult<Thread>(Thread.currentThread()); in e1Work()
/dports/devel/py-celery/celery-4.4.7/t/unit/contrib/
H A Dtest_abortable.py18 self.abortable.AsyncResult(tid), AbortableAsyncResult)
30 self.abortable.AsyncResult = self.app.AsyncResult
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/System.Net/
H A DDns.cs239 AsyncResult async = (AsyncResult) asyncResult; in EndGetHostByName()
255 AsyncResult async = (AsyncResult) asyncResult; in EndResolve()
274 AsyncResult async = (AsyncResult) asyncResult; in EndGetHostAddresses()
289 AsyncResult async = (AsyncResult) asyncResult; in EndGetHostEntry()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Activities/System/ServiceModel/Activities/Dispatcher/
H A DPersistenceContext.cs720 class CloseAsyncResult : AsyncResult
760 AsyncResult.End<CloseAsyncResult>(result); in End()
763 void OnFinishOperation(AsyncResult result, Exception exception) in OnFinishOperation()
903 AsyncResult.End<SaveAsyncResult>(result); in End()
950 void OnFinishOperation(AsyncResult result, Exception exception) in OnFinishOperation()
1060 AsyncResult.End<ReleaseAsyncResult>(result); in End()
1102 void OnFinishOperation(AsyncResult result, Exception exception) in OnFinishOperation()
1202 AsyncResult.End<AssociateKeysAsyncResult>(result); in End()
1295 void OnFinishOperation(AsyncResult result, Exception exception) in OnFinishOperation()
1316 class UpdateSuspendMetadataAsyncResult : AsyncResult
[all …]
/dports/devel/php-ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/background/
H A DAllTests.java335 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
336 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
374 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
375 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
400 java.util.List<Ice.AsyncResult> results = new java.util.ArrayList<Ice.AsyncResult>(); in allTests()
415 for(Ice.AsyncResult r : results) in allTests()
460 Ice.AsyncResult r = prx.begin_op(); in connectTests()
571 Ice.AsyncResult r = prx.begin_op(); in initializeTests()
830 Ice.AsyncResult r = prx.begin_op(); in validationTests()
895 Ice.AsyncResult r = background.begin_op(); in validationTests()
[all …]
/dports/devel/ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/background/
H A DAllTests.java335 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
336 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
374 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
375 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
400 java.util.List<Ice.AsyncResult> results = new java.util.ArrayList<Ice.AsyncResult>(); in allTests()
415 for(Ice.AsyncResult r : results) in allTests()
460 Ice.AsyncResult r = prx.begin_op(); in connectTests()
571 Ice.AsyncResult r = prx.begin_op(); in initializeTests()
830 Ice.AsyncResult r = prx.begin_op(); in validationTests()
895 Ice.AsyncResult r = background.begin_op(); in validationTests()
[all …]
/dports/devel/py-ice37/ice-3.7.2/java-compat/test/src/main/java/test/Ice/background/
H A DAllTests.java335 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
336 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
374 Ice.AsyncResult r1 = bg.begin_op(); in allTests()
375 Ice.AsyncResult r2 = bg.begin_op(); in allTests()
400 java.util.List<Ice.AsyncResult> results = new java.util.ArrayList<Ice.AsyncResult>(); in allTests()
415 for(Ice.AsyncResult r : results) in allTests()
460 Ice.AsyncResult r = prx.begin_op(); in connectTests()
571 Ice.AsyncResult r = prx.begin_op(); in initializeTests()
830 Ice.AsyncResult r = prx.begin_op(); in validationTests()
895 Ice.AsyncResult r = background.begin_op(); in validationTests()
[all …]
/dports/devel/py-RPyC/rpyc-5.0.1/docs/tutorial/
H A Dtut5.rst14 ``AsyncResult`` (also known as a `"future" or "promise" <http://en.wikipedia.org/wiki/Futures_and_p…
21 wrapper function that will return an ``AsyncResult`` instead of blocking. ``AsyncResult``
28 * ``expired`` - indicates whether the AsyncResult object is expired (its time-to-wait has
32 * ``value`` - the value contained in the AsyncResult. If the value has not yet arrived,
41 * ``set_expiry(seconds)`` - sets the expiry time of the AsyncResult. By default, no
58 # invoking async functions yields an AsyncResult rather than a value
61 <AsyncResult object (pending) at 0x0842c6bc>
73 <AsyncResult object (ready) at 0x0842c6bc>
82 <AsyncResult object (pending) at 0x0844992c>
93 <AsyncResult object (pending) at 0x0847cb0c>
/dports/mail/py-python-slimta/python-slimta-4.2.1/test/
H A Dtest_slimta_relay_smtp_client.py8 from gevent.event import AsyncResult
177 result = AsyncResult()
198 result = AsyncResult()
216 result = AsyncResult()
236 result = AsyncResult()
254 result = AsyncResult()
273 result = AsyncResult()
293 result = AsyncResult()
327 result = AsyncResult()
378 result = AsyncResult()
[all …]
/dports/devel/py-kazoo/kazoo-2.5.0/kazoo/handlers/
H A Deventlet.py42 class AsyncResult(utils.AsyncResult): class
45 super(AsyncResult, self).__init__(handler,
166 return AsyncResult(self)
/dports/graphics/openvkl/openvkl-1.1.0/testing/volume/
H A DOpenVdbVolume.h67 new rkcommon::tasking::AsyncTask<AsyncResult>([=]() { in updateVolume()
69 AsyncResult result; in updateVolume()
93 AsyncResult result = asyncLoader->get(); in updateVolume()
129 struct AsyncResult struct
149 std::unique_ptr<rkcommon::tasking::AsyncTask<AsyncResult>> asyncLoader;
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/tracing/ipc/consumer/
H A Dconsumer_ipc_client_impl.h95 ipc::AsyncResult<protos::gen::ReadBuffersResponse>);
97 ipc::AsyncResult<protos::gen::EnableTracingResponse>);
99 ipc::AsyncResult<protos::gen::QueryServiceStateResponse>,
/dports/graphics/osgearth/osgearth-osgearth-2.10.1/src/osgEarth/
H A DAsync.cpp39 AsyncResult::AsyncResult(osg::Node* node) : in AsyncResult() function in AsyncResult
178 AsyncResult* ar = dynamic_cast<AsyncResult*>(node); in addChild()
378 osg::ref_ptr<AsyncResult> result = new AsyncResult(r.releaseNode()); in readNode()
/dports/misc/gedkeeper/GEDKeeper-2.19.1/projects/GKMap/GKMap.Core/ProxySocket/
H A DSocks4Handler.cs157 AsyncResult = new IAsyncProxyResult(); in BeginNegotiate()
158 return AsyncResult; in BeginNegotiate()
172 AsyncResult = new IAsyncProxyResult(); in BeginNegotiate()
173 return AsyncResult; in BeginNegotiate()
/dports/security/zeronet/ZeroNet-0.7.1/src/util/
H A DPooled.py13 if type(res) == gevent.event.AsyncResult:
26 evt = gevent.event.AsyncResult()
48 evt = gevent.event.AsyncResult()
/dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCallbackBase.java9 public abstract void _iceCompleted(Ice.AsyncResult r); in _iceCompleted()
10 public abstract void _iceSent(Ice.AsyncResult r); in _iceSent()
/dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCallbackBase.java9 public abstract void _iceCompleted(Ice.AsyncResult r); in _iceCompleted()
10 public abstract void _iceSent(Ice.AsyncResult r); in _iceSent()
/dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/
H A DCallbackBase.java9 public abstract void _iceCompleted(Ice.AsyncResult r); in _iceCompleted()
10 public abstract void _iceSent(Ice.AsyncResult r); in _iceSent()

12345678910>>...53