Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 199 for canceler (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top