- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for peek (0.28 sec)
-
android/guava/src/com/google/common/collect/Iterators.java
* Iterators.peekingIterator(Iterators.forArray("a", "b")); * String a1 = peekingIterator.peek(); // returns "a" * String a2 = peekingIterator.peek(); // also returns "a" * String a3 = peekingIterator.next(); // also returns "a" * }</pre> * * <p>Any structural changes to the underlying iteration (aside from those performed by the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Sat Apr 20 03:33:06 GMT 2024 - 50.6K bytes - Viewed (0) -
cmd/metacache-stream.go
if r.creator == nil || r.err != nil { return } r.err = r.creator() r.creator = nil } // peek will return the name of the next object. // Will return io.EOF if there are no more objects. // Should be used sparingly. func (r *metacacheReader) peek() (metaCacheEntry, error) { r.checkInit() if r.err != nil { return metaCacheEntry{}, r.err } if r.current.name != "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycles.java
}; Map<String, Lifecycle> lifecyclesMap = lookupLifecycles(); // ensure canonical order of standard lifecycles return lifecyclesMap.values().stream() .peek(l -> Objects.requireNonNull(l.getId(), "A lifecycle must have an id.")) .sorted(Comparator.comparing(Lifecycle::getId, comparator)) .collect(Collectors.toList()); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
name: String, defaultValue: String?, ): String? = headers[name] ?: defaultValue @Throws(IOException::class) fun Response.commonPeekBody(byteCount: Long): ResponseBody { val peeked = body.source().peek() val buffer = Buffer() peeked.request(byteCount) buffer.write(peeked, minOf(byteCount, peeked.buffer.size)) return buffer.asResponseBody(body.contentType(), buffer.size) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/untar.go
"github.com/pierrec/lz4" ) // Max bzip2 concurrency across calls. 50% of GOMAXPROCS. var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2) func detect(r *bufio.Reader) format { z, err := r.Peek(4) if err != nil { return formatUnknown } for _, f := range magicHeaders { if bytes.Equal(f.header, z[:len(f.header)]) { return f.f } } return formatUnknown }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AbstractGradleViolationRule.groovy
if (method.changeStatus == JApiChangeStatus.REMOVED) { return false } // @Override has source retention - so we need to peek into the sources return repository.isOverride(method) } Violation acceptOrReject(JApiCompatibility member, Violation rejection) {
Groovy - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Tue Apr 23 08:40:36 GMT 2024 - 10.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
delegate.put(element) editCount++ } } override fun iterator() = error("unsupported") override fun offer(e: T) = error("unsupported") override fun peek(): T = error("unsupported") override fun offer( element: T, timeout: Long, unit: TimeUnit, ) = error("unsupported") override fun take() = error("unsupported")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
archiveTypeMetadataKey = ReservedMetadataPrefixLower + "archive-type" // "x-minio-internal-archive-type" archiveInfoMetadataKey = ReservedMetadataPrefixLower + "archive-info" // "x-minio-internal-archive-info" // Peek into a zip archive xMinIOExtract = "x-minio-extract" ) // splitZipExtensionPath splits the S3 path to the zip file and the path inside the zip: //
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/metacache-set.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
} catch (e: IOException) { throw RuntimeException(e) } } return result } override fun peek(): MockResponse = queueDispatcher.peek() override fun shutdown() { queueDispatcher.shutdown() } } client = client.newBuilder() .proxy(server.toProxyAddress())
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0)