- Sort Score
- Num 10 results
- Language All
Results 461 - 470 of 1,204 for chan (0.03 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
docs/de/docs/_llm-test.md
Die Tests: ## Codeschnipsel { #code-snippets } //// tab | TestCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 07:17:04 GMT 2025 - 12.6K bytes - Click Count (0) -
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) -
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)