- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 420 for Select1 (0.05 seconds)
-
tests/hooks_test.go
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Jun 17 03:59:06 GMT 2024 - 16.7K bytes - Click Count (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
skipWhitespace() val type = select(optionsType) when (type) { TYPE_DEVIATION, TYPE_MAPPED, TYPE_DISALLOWED_STD3_MAPPED -> { skipWhitespace() if (readByte() != ';'.code.toByte()) throw IOException("expected ';'") // Like "0061" or "0031 2044 0034". while (true) { skipWhitespace() when (select(optionsDelimiter)) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6.9K bytes - Click Count (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
*/ @Throws(IOException::class) fun processNextEvent(): Boolean { var id = lastId var type: String? = null val data = Buffer() while (true) { when (source.select(options)) { in 0..2 -> { completeEvent(id, type, data) return true } in 3..4 -> { source.readData(data) } in 5..7 -> {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 4.3K bytes - Click Count (0) -
.github/workflows/extract-unit-test-split.jq
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Oct 11 08:08:26 GMT 2021 - 171 bytes - Click Count (0) -
android/guava-tests/test/com/google/common/math/QuantilesAlgorithm.java
if (array[min] > array[i]) { min = i; } } return array[min]; } static double select(int k, double[] array) { // This is basically a copy of com.google.math.Rank#select, with a small change in the method // signature: we make k 0-based rather than 1-based; and we drop from and to, and always work on // the whole array. int from = 0;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 05:21:26 GMT 2026 - 7.3K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven4ScopeManagerConfiguration.java
select(CommonBuilds.PROJECT_PATH_TEST, CommonBuilds.BUILD_PATH_COMPILE), Collections.singletonList(system), nonTransitiveDependencyScopes)); result.add(internalScopeManager.createResolutionScope( RS_TEST_RUNTIME, InternalScopeManager.Mode.ELIMINATE,Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 9.2K bytes - Click Count (0) -
internal/once/singleton.go
} // GetNonBlocking will return the singleton value or nil if not set yet. func (s *Singleton[T]) GetNonBlocking() *T { select { case <-s.set: return s.v default: return nil } } // IsSet will return whether the singleton has been set. func (s *Singleton[T]) IsSet() bool { select { case <-s.set: return true default: return false } } // Set the value and unblock all Get requests.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 952 bytes - Click Count (0) -
internal/grid/stream.go
muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select { case s.Requests <- b: return nil case <-s.ctx.Done(): return context.Cause(s.ctx) } } // Results returns the results from the remote server one by one.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jun 07 15:51:52 GMT 2024 - 3.1K bytes - Click Count (0) -
internal/bpool/bpool.go
bp.Put(buf[:bp.w]) } } // Get gets a []byte from the BytePool, or creates a new one if none are // available in the pool. func (bp *BytePoolCap) Get() (b []byte) { if bp == nil { return nil } select { case b = <-bp.c: // reuse existing buffer default: // create new aligned buffer b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w] } return b } // Put returns the given Buffer to the BytePool.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3K bytes - Click Count (0) -
buildscripts/verify-healing-empty-erasure-set.sh
# Wait for all drives to be online and formatted while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done # Wait for all drives to be healed while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done # Wait for Status: in MinIO output while true; do rv=$(check_online)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 3.7K bytes - Click Count (0)