Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 461 - 470 of 1,204 for chan (0.03 seconds)

  1. guava/src/com/google/common/net/InetAddresses.java

       *
       * <p>As long as there are applications that assume that all IP addresses are IPv4 addresses and
       * can therefore be converted safely to integers (for whatever purpose) this function can be used
       * to handle IPv6 addresses as well until the application is suitably fixed.
       *
       * <p>NOTE: an IPv6 address coerced to an IPv4 address can only be used for such purposes as
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 47.4K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

          client
            .newBuilder()
            .protocols(listOf(Protocol.H2_PRIOR_KNOWLEDGE))
            .socketFactory(socketFactory)
            .addNetworkInterceptor(
              Interceptor { chain ->
                try {
                  chain.proceed(chain.request())
                } finally {
                  firstConnectLatch.countDown()
                }
              },
            ).build()
    
        // Set up a same-connection retry.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/io/CharSourceTest.java

        BufferedReader reader = source.openBufferedStream();
        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  4. tensorflow/c/c_api_experimental_test.cc

      TF_DeletePluggableDeviceLibraryHandle(lib);
    #endif  // !defined(TENSORFLOW_NO_SHARED_OBJECTS)
    #endif  // !defined(PLATFORM_WINDOWS)
    }
    
    void DefineFunction(const char* name, TF_Function** func,
                        const char* description = nullptr,
                        bool append_hash = false) {
      std::unique_ptr<TF_Graph, decltype(&TF_DeleteGraph)> func_graph(
          TF_NewGraph(), TF_DeleteGraph);
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Tue Jan 17 22:27:52 GMT 2023
    - 13.1K bytes
    - Click Count (0)
  5. docs/batch-jobs/README.md

      # optional flags based filtering criteria
      # for all source objects
      flags:
    	filter:
    	  newerThan: "7d" # match objects newer than this value (e.g. 7d10h31s)
    	  olderThan: "7d" # match objects older than this value (e.g. 7d10h31s)
    	  createdAfter: "date" # match objects created after "date"
    	  createdBefore: "date" # match objects created before "date"
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 06 06:00:43 GMT 2022
    - 4.8K bytes
    - Click Count (0)
  6. cmd/streaming-signature-v4_test.go

    			errLineTooLong,
    			nil,
    			nil,
    		},
    		// Test - 2 - unexpected end of the reader.
    		{
    			bufio.NewReader(readers[1]),
    			io.ErrUnexpectedEOF,
    			nil,
    			nil,
    		},
    		// Test - 3 - line too long bigger than 4k+1
    		{
    			bufio.NewReader(readers[2]),
    			errLineTooLong,
    			nil,
    			nil,
    		},
    		// Test - 4 - parse the chunk reader properly.
    		{
    			bufio.NewReader(readers[3]),
    			nil,
    			[]byte("1000"),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  7. architecture/standards/0006-use-of-provider-apis-in-gradle.md

    If the nested type is a managed type (Gradle can generate its implementation), you can define a nested property with:
    ```
    interface NestedType {
        Property<String> getSomeProperty()
    }
    class Example {
        @Nested
        NestedType getNestedProperty()
    }
    ```
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Oct 15 20:00:57 GMT 2024
    - 10K bytes
    - Click Count (0)
  8. docs/de/docs/_llm-test.md

    Die Tests:
    
    ## Codeschnipsel { #code-snippets }
    
    //// tab | Test
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 07:17:04 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  9. docs/ja/docs/advanced/websockets.md

    試してみるには、
    
    * いくつかのブラウザタブでアプリを開きます。
    * それらのタブでメッセージを記入してください。
    * そして、タブのうち1つを閉じてください。
    
    これにより例外 `WebSocketDisconnect` が発生し、他のすべてのクライアントは次のようなメッセージを受信します。
    
    ```
    Client #1596980209979 left the chat
    ```
    
    /// tip | 豆知識
    
    上記のアプリは、複数の WebSocket 接続に対してメッセージを処理し、ブロードキャストする方法を示すための最小限のシンプルな例です。
    
    しかし、すべての接続がメモリ内の単一のリストで処理されるため、プロセスの実行中にのみ機能し、単一のプロセスでのみ機能することに注意してください。
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  10. cmd/local-locker.go

    }
    
    func (l *localLocker) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if len(args.Resources) > maxDeleteList {
    		return false, fmt.Errorf("internal error: localLocker.Lock called with more than %d resources", maxDeleteList)
    	}
    
    	// If we have too many waiting, reject this at once.
    	if l.waitMutex.Load() > lockMutexWaitLimit {
    		l.locksOverloaded.Add(1)
    		return false, nil
    	}
    	// Wait for mutex
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
Back to Top