- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,169 for source (0.19 sec)
-
guava-tests/test/com/google/common/io/CharSourceTester.java
String string = source.read(); assertExpectedString(string); } public void testReadFirstLine() throws IOException { if (expectedLines.isEmpty()) { assertNull(source.readFirstLine()); } else { assertEquals(expectedLines.get(0), source.readFirstLine()); } } public void testReadLines_toList() throws IOException { assertExpectedLines(source.readLines()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 7.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Transport.java
* @throws RuntimeException If failed (and not due source not exists). */ boolean get(@Nonnull URI relativeSource, @Nonnull Path target); /** * GETs the source URI content as byte array. The source MUST BE relative from the {@link RemoteRepository#getUrl()} * root. * * @return the byte array if operation succeeded, {@code null} if source does not exist.
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Mar 23 05:29:39 GMT 2023 - 4.4K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
*/ internal class DerReader(source: Source) { private val countingSource: CountingSource = CountingSource(source) private val source: BufferedSource = countingSource.buffer() /** Total bytes read thus far. */ private val byteCount: Long get() = countingSource.bytesRead - source.buffer.size
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProjectBuilder.java
private final Source source; SourceWrapper(Source source) { this.source = source; } @Override public InputStream getInputStream() throws IOException { return source.openStream(); } @Override public String getLocation() { return source.getLocation(); } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 8.3K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
resource := "test" runtime.GOMAXPROCS(gomaxprocs) // Number of active readers + 10000 * number of active writers. var activity int32 cdone := make(chan bool) go writer(resource, numIterations, &activity, cdone) var i int for i = 0; i < numReaders/2; i++ { go reader(resource, numIterations, &activity, cdone) } go writer(resource, numIterations, &activity, cdone)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock) } // GetRLock tries to get a read lock on lm before the timeout occurs. func (lm *LRWMutex) GetRLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) { const isWriteLock = false return lm.lockLoop(ctx, id, source, timeout, isWriteLock) } func (lm *LRWMutex) lock(id, source string, isWriteLock bool) (locked bool) { lm.mu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v2beta1/generated.proto
// normal per-pod metrics using the "pods" source. Only one "target" type // should be set. message ContainerResourceMetricSource { // name is the name of the resource in question. optional string name = 1; // targetAverageUtilization is the target value of the average of the // resource metric across all relevant pods, represented as a percentage of // the requested value of the resource for the pods. // +optional
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/UpgradeUtil.java
return putMapping(indicesClient, index, null, source); } public static boolean putMapping(final IndicesAdminClient indicesClient, final String index, final String type, final String source) { try { final PutMappingRequestBuilder builder = indicesClient.preparePutMapping(index).setSource(source, XContentType.JSON);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LittleEndianByteArray.java
@Override public long getLongLittleEndian(byte[] source, int offset) { return Longs.fromBytes( source[offset + 7], source[offset + 6], source[offset + 5], source[offset + 4], source[offset + 3], source[offset + 2], source[offset + 1], source[offset]); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 9.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
while (true) { when (source.select(options)) { in 0..2 -> { completeEvent(id, type, data) return true } in 3..4 -> { source.readData(data) } in 5..7 -> { data.writeByte('\n'.code) // 'data' on a line of its own. } in 8..9 -> { id = source.readUtf8LineStrict().takeIf { it.isNotEmpty() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0)