- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 199 for canceler (0.26 sec)
-
android/guava/src/com/google/common/util/concurrent/FutureCallback.java
/** Invoked with the result of the {@code Future} computation when it is successful. */ void onSuccess(@ParametricNullness V result); /** * Invoked when a {@code Future} computation fails or is canceled. * * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then * the cause is passed to this method. Any other thrown object is passed unaltered. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java
import jcifs.internal.util.SMBUtil; /** * SMB2 Cancel request message. * * This command is used to cancel a previously sent command * that is still being processed by the server. * * @author mbechler */ public class Smb2CancelRequest extends ServerMessageBlock2 implements CommonServerMessageBlockRequest { /** * Constructs a SMB2 cancel request * * @param config
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 7.3K bytes - Viewed (0) -
src/main/resources/fess_label_es.properties
labels.crawling_info_created_time=Creado labels.crawling_info_delete_all_link=Eliminar todo labels.crawling_info_delete_all_confirmation=¿Está seguro de que desea eliminar todo? labels.crawling_info_delete_all_cancel=Cancelar labels.crawling_info_thread_dump=Volcado de hilos labels.crawling_info_CrawlerStartTime=Hora de inicio del rastreador labels.crawling_info_CrawlerEndTime=Hora de finalización del rastreador
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 10 04:56:21 UTC 2025 - 45.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbWatchHandleImpl.java
} catch (final SmbException e) { if (e.getNtStatus() == 0xC0000120) { // cancelled log.debug("Request was cancelled", e); return null; } throw e; } if (log.isTraceEnabled()) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 4.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
) = TODO() override fun callEnd(call: Call) = TODO() override fun callFailed( call: Call, ioe: IOException, ) = TODO() override fun canceled(call: Call) = TODO() } val none: EventListener = EventListener.NONE } @Test fun eventListenerBuilder() { var builder: EventListener.Factory = EventListener.Factory { TODO() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 46.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FutureCallback.java
/** Invoked with the result of the {@code Future} computation when it is successful. */ void onSuccess(@ParametricNullness V result); /** * Invoked when a {@code Future} computation fails or is canceled. * * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then * the cause is passed to this method. Any other thrown object is passed unaltered. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java
/** * Last fragment flag - indicates last fragment of a multi-fragment message */ int DCERPC_LAST_FRAG = 0x02; /* Last fragment */ /** * Pending cancel flag - indicates cancel was pending at sender */ int DCERPC_PENDING_CANCEL = 0x04; /* Cancel was pending at sender */ /** * Reserved flag for future use */ int DCERPC_RESERVED_1 = 0x08; /** * Supports concurrent multiplexing flag
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
okhttp-coroutines/README.md
that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call. Cancelling a call, will throw a CancellationException
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Nov 09 15:47:27 UTC 2023 - 609 bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt
* earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and * those implied by the returned execution delay. * * Cancellation * ------------ * * Tasks may be canceled while they are waiting to be executed, or while they are executing. * * Canceling a task that is waiting to execute prevents that upcoming execution. Canceling a task
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0)