Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 492 for cancel (0.04 seconds)

  1. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        /**
         * Executes the thumbnail generator process.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  2. okhttp/src/androidMain/baseline-prof.txt

    PLkotlinx/coroutines/JobCancellationException;->fillInStackTrace()Ljava/lang/Throwable;
    PLkotlinx/coroutines/JobImpl;->getOnCancelComplete$kotlinx_coroutines_core()Z
    PLkotlinx/coroutines/JobKt;->cancel$default(Lkotlin/coroutines/CoroutineContext;Ljava/util/concurrent/CancellationException;ILjava/lang/Object;)V
    PLkotlinx/coroutines/JobSupport$Finishing;-><init>(Lkotlinx/coroutines/NodeList;ZLjava/lang/Throwable;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
  3. docs/changelogs/changelog_2x.md

        requests couldn't be canceled by tag. This update avoids crashing when
        `onResponse()` throws an `IOException`. That failure will now be logged
        instead of notifying the thread's uncaught exception handler. We've added a
        new API, `Call.isCanceled()` to check if a call has been canceled.
    
     *  New: Update `MultipartBuilder` to support content length.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/collect/QueuesTest.java

          assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
    
          // If even the first one wasn't there, clean up so that the next test doesn't see an element.
          producerThread.cancel(true);
          producer.doneProducing.await();
          if (drained == 0) {
            q.poll(); // not necessarily there if producer was interrupted
          }
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/chat/ChatSessionManager.java

        /**
         * Destroys the session manager and shuts down the cleanup scheduler.
         */
        @PreDestroy
        public void destroy() {
            if (cleanupTask != null && !cleanupTask.isCanceled()) {
                cleanupTask.cancel();
            }
        }
    
        /**
         * Creates a new chat session.
         *
         * @param userId the user ID (can be null for anonymous users)
         * @return the created session
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 07 13:27:59 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/gcs/GcsClient.java

                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
         * Parses a GCS path into bucket name and object path components.
         * @param path the GCS path to parse (format: bucket/object/path)
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Dec 11 08:38:29 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
       * operation is required.
       *
       * This is invoked at most once, even if [Call.cancel] is invoked multiple times. It may be
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * call this without consuming the complete response body, any remaining bytes in the response
       * body will be discarded before trailers are returned.
       *
       * If [Call.cancel] is called while this is blocking, this call will immediately throw.
       *
       * @throws IllegalStateException if the response is closed.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  9. api/go1.5.txt

    pkg mime/quotedprintable, type Writer struct, Binary bool
    pkg net, type Dialer struct, FallbackDelay time.Duration
    pkg net, type OpError struct, Source Addr
    pkg net/http, type Request struct, Cancel <-chan struct
    pkg net/http/fcgi, var ErrConnClosed error
    pkg net/http/fcgi, var ErrRequestAborted error
    pkg net/http/pprof, func Trace(http.ResponseWriter, *http.Request)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jul 30 21:14:09 GMT 2015
    - 46.6K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            val call = chain.call()
            callRef.set(call)
            assertThat(call.isCanceled()).isFalse()
            call.cancel()
            assertThat(call.isCanceled()).isTrue()
            chain.proceed(chain.request())
          }
        client =
          client
            .newBuilder()
            .addInterceptor(interceptor)
            .build()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
Back to Top