Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for CompletableFuture (0.09 sec)

  1. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

     * </ul>
     *
     * <h4>{@link java.util.concurrent.CompletableFuture} / {@link java.util.concurrent.CompletionStage}
     * </h4>
     *
     * <p>Users of {@code CompletableFuture} will likely want to continue using {@code
     * CompletableFuture}. {@code FluentFuture} is targeted at people who use {@code ListenableFuture},
     * who can't use Java 8, or who want an API more focused than {@code CompletableFuture}. (If you
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  2. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

        val negotiatedProtocol: String,
        val content: String,
      )
    
      private fun execute(
        engine: HttpEngine,
        executor: ExecutorService,
        url: String,
      ): CompletableFuture<Response> {
        val completableFuture = CompletableFuture<Response>()
        val buffer = Buffer()
    
        val req =
          engine
            .newUrlRequestBuilder(
              url,
              executor,
              object : Callback {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/witness/WitnessClient.java

            // Stop all async notification tasks first
            List<CompletableFuture<Void>> taskFutures = new ArrayList<>(asyncNotifyTasks.values());
            for (CompletableFuture<Void> task : taskFutures) {
                task.cancel(true);
            }
            asyncNotifyTasks.clear();
    
            // Unregister all active registrations
            List<CompletableFuture<Void>> unregisterFutures = new ArrayList<>();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  4. docs/smb3-features/06-witness-protocol-design.md

        }
        
        public CompletableFuture<WitnessRegistration> registerForNotifications(
                String shareName, 
                InetAddress serverAddress,
                WitnessNotificationListener listener) {
            
            return CompletableFuture.supplyAsync(() -> {
                try {
                    // Create registration
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 42K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/persistent/HandleReconnector.java

         */
        public CompletableFuture<HandleInfo> reconnectHandle(HandleInfo handleInfo, Exception cause) {
            if (handleInfo == null) {
                return CompletableFuture.failedFuture(new IOException("Handle info cannot be null"));
            }
    
            if (handleInfo.isExpired()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 8.5K bytes
    - Viewed (1)
  6. src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java

    import static org.mockito.Mockito.never;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.io.IOException;
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ExecutionException;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.mockito.Mock;
    import org.mockito.MockitoAnnotations;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

    import assertk.assertions.isNotNull
    import assertk.fail
    import java.io.IOException
    import java.net.ServerSocket
    import java.net.Socket
    import java.net.SocketException
    import java.util.concurrent.CompletableFuture
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.DelegatingServerSocketFactory
    import okhttp3.DelegatingSocketFactory
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

             */
            public CompletableFuture<Void> getNotificationFuture() {
                return notificationFuture;
            }
    
            /**
             * Sets the future for asynchronous notification completion
             * @param future the notification future to set
             */
            public void setNotificationFuture(CompletableFuture<Void> future) {
                this.notificationFuture = future;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  9. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceFactoryTest.java

            .body("data: hello\n\n")
            .setHeader("content-type", "text/event-stream")
            .build()
        );
        Request request = new Request.Builder().url(server.url("/")).build();
        CompletableFuture<Void> future = new CompletableFuture<>();
        factory.newEventSource(request, new EventSourceListener() {
          @Override
          public void onOpen(@NotNull EventSource eventSource, @NotNull Response response) {
            try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/witness/WitnessClientTest.java

    import static org.mockito.Mockito.lenient;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.net.InetAddress;
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 09:06:40 UTC 2025
    - 9.8K bytes
    - Viewed (0)
Back to top