Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 474 for accepted (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/collect/testing/SpliteratorTester.java

              forEach(prefix, consumer);
            }
            long size = spliterator.getExactSizeIfKnown();
            long[] counter = {0};
            spliterator.forEachRemaining(
                e -> {
                  consumer.accept(e);
                  counter[0]++;
                });
            if (size >= 0) {
              assertEquals(size, counter[0]);
            }
          }
        },
        ALTERNATE_ADVANCE_AND_SPLIT {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  2. src/bufio/net_test.go

    	}
    
    	// Start a goroutine for the server to accept one connection
    	// and read all the data sent on the connection,
    	// reporting the number of bytes read on ch.
    	ch := make(chan int, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    
    		tot := 0
    		defer func() {
    			ch <- tot
    		}()
    
    		serverConn, err := server.Accept()
    		if err != nil {
    			t.Error(err)
    			return
    		}
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 19:37:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

       * network interceptors return.
       */
      internal var interceptorScopedExchange: Exchange? = null
        private set
    
      // These properties are guarded by `this`. They are typically only accessed by the thread executing
      // the call, but they may be accessed by other threads for duplex requests.
    
      private var requestBodyOpen = false
      private var responseBodyOpen = false
      private var socketSinkOpen = false
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

      fun missingConnectionHeader() {
        webServer.enqueue(
          MockResponse
            .Builder()
            .code(101)
            .setHeader("Upgrade", "websocket")
            .setHeader("Sec-WebSocket-Accept", "ujmZX4KXZqjwy6vi1aQFH5p4Ygk=")
            .build(),
        )
        webServer.enqueue(
          MockResponse
            .Builder()
            .onRequestStart(CloseSocket())
            .build(),
        )
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionError.java

       * `public final Error getCause()`.)
       */
    
      /**
       * Creates a new instance with {@code null} as its detail message and no cause.
       *
       * @deprecated Prefer {@linkplain ExecutionError(Error)} a constructor that accepts a cause: Users
       *     of this class typically expect for instances to have a non-null cause. At the moment, you
       *     can <i>usually</i> still preserve behavior by passing an explicit {@code null} cause. Note,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/logging/LoggingOutputStream.java

                ProjectBuildLogAppender.updateMdc();
                consumer.accept(line);
                buf.reset();
            }
        }
    
        public void forceFlush() {
            if (buf.size() > 0) {
                String line = new String(buf.toByteArray(), 0, buf.size());
                ProjectBuildLogAppender.updateMdc();
                consumer.accept(line);
                buf.reset();
            }
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Feb 12 12:31:43 GMT 2025
    - 3K bytes
    - Click Count (0)
  7. okhttp/src/commonTest/kotlin/okhttp3/CompressionInterceptorTest.kt

        val empty = CompressionInterceptor()
        val client =
          clientTestRule
            .newClientBuilder()
            .addInterceptor(empty)
            .addInterceptor { chain ->
              assertThat(chain.request().header("Accept-Encoding")).isNull()
              Response
                .Builder()
                .request(chain.request())
                .protocol(Protocol.HTTP_1_1)
                .code(200)
                .message("OK")
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Aug 01 06:04:22 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

        }
    
        @Override public SocketAddress getLocalSocketAddress() {
          return endpoint;
        }
    
        @Override public Socket accept() throws IOException {
          try {
            UnixSocketChannel channel = serverSocketChannel.accept();
            return new TunnelingUnixSocket(path, channel, endpoint);
          } catch (ClosedChannelException e) {
            SocketException exception = new SocketException();
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 3.1K bytes
    - Click Count (0)
  9. guava-testlib/src/com/google/common/testing/CollectorTester.java

              A result(Collector<T, A, R> collector, Iterable<T> inputs) {
            A accum = collector.supplier().get();
            for (T input : inputs) {
              collector.accumulator().accept(accum, input);
            }
            return accum;
          }
        },
        /** Get one accumulator for each element and merge the accumulators left-to-right. */
        MERGE_LEFT_ASSOCIATIVE {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu May 15 21:47:56 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  10. docs/fr/docs/deployment/versions.md

    ```txt
    fastapi>=0.45.0,<0.46.0
    ```
    
    cela signifierait que vous utiliseriez les versions `0.45.0` ou supérieures, mais inférieures à `0.46.0`, par exemple, une version `0.45.2` serait toujours acceptée.
    
    Si vous utilisez un autre outil pour gérer vos installations, comme Poetry, Pipenv, ou autres, ils ont tous un moyen que vous pouvez utiliser pour définir des versions spécifiques pour vos paquets.
    
    ## Versions disponibles
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Nov 09 16:39:20 GMT 2024
    - 4.1K bytes
    - Click Count (0)
Back to Top