- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 69 for delimiter (0.17 sec)
-
guava/src/com/google/common/collect/FluentIterable.java
* {@code joiner}. * * <p><b>{@code Stream} equivalent:</b> {@code joiner.join(stream.iterator())}, or, if you are not * using any optional {@code Joiner} features, {@code * stream.collect(Collectors.joining(delimiter)}. * * @since 18.0 */ public final String join(Joiner joiner) { return joiner.join(this); } /** * Returns the element at the specified position in this fluent iterable.
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Tue Jan 30 00:14:39 GMT 2024 - 35.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HttpUrlTest.kt
.isEqualTo(parse("http://host/path")) assertThat(parse("http://user@host/path")) .isEqualTo(parse("http://user@host/path")) } /** * Given multiple '@' characters, the last one is the delimiter. */ @Test fun authorityWithMultipleAtSigns() { val httpUrl = parse("http://foo@bar@baz/path") assertThat(httpUrl.username).isEqualTo("foo@bar") assertThat(httpUrl.password).isEqualTo("")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 67.9K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrParseExpectedArgumentDelimiter: { Code: "ParseExpectedArgumentDelimiter", Description: "Did not find the expected argument delimiter in the SQL expression.", HTTPStatusCode: http.StatusBadRequest, }, ErrParseCastArity: { Code: "ParseCastArity", Description: "The SQL expression CAST has incorrect arity.",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (6) -
common-protos/k8s.io/api/extensions/v1beta1/generated.proto
// URI as defined in RFC 3986: // 1. IPs are not allowed. Currently an IngressRuleValue can only apply to // the IP in the Spec of the parent Ingress. // 2. The `:` delimiter is not respected because ports are not allowed. // Currently the port of an Ingress is implicitly :80 for http and // :443 for https. // Both these may change in the future.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 45.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
} return this } private fun resolvePath( input: String, startPos: Int, limit: Int, ) { var pos = startPos // Read a delimiter. if (pos == limit) { // Empty path: keep the base path as-is. return } val c = input[pos] if (c == '/' || c == '\\') {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
cmd/server_test.go
Initiator Initiator Owner Owner StorageClass string Initiated time.Time // Keep this native to be able to parse properly. } Prefix string Delimiter string CommonPrefixes []CommonPrefix } // parse the response body. decoder = xml.NewDecoder(response3.Body) newResponse3 := &listMultipartUploadsResponse{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
throttle, ok := m.bucketsThrottle[BucketOptions{Name: bucket, ReplicationARN: arn}] if !ok { throttle = &bucketThrottle{} } throttle.NodeBandwidthPerSec = limitBytes throttle.Limiter = rate.NewLimiter(rate.Limit(float64(limitBytes)), int(limitBytes)) m.bucketsThrottle[BucketOptions{Name: bucket, ReplicationARN: arn}] = throttle } // IsThrottled returns true if a bucket has bandwidth throttling enabled.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(Double.POSITIVE_INFINITY, stopwatch); limiter.acquire(Integer.MAX_VALUE / 4); limiter.acquire(Integer.MAX_VALUE / 2); limiter.acquire(Integer.MAX_VALUE); assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate! limiter.setRate(2.0); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter limiter = RateLimiter.create(Double.POSITIVE_INFINITY, stopwatch); limiter.acquire(Integer.MAX_VALUE / 4); limiter.acquire(Integer.MAX_VALUE / 2); limiter.acquire(Integer.MAX_VALUE); assertEvents("R0.00", "R0.00", "R0.00"); // no wait, infinite rate! limiter.setRate(2.0); limiter.acquire(); limiter.acquire(); limiter.acquire(); limiter.acquire();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.6K bytes - Viewed (0) -
fastapi/concurrency.py
# since we're creating a new limiter for each call, any non-zero limit # works (1 is arbitrary) exit_limiter = CapacityLimiter(1) try: yield await run_in_threadpool(cm.__enter__) except Exception as e: ok = bool( await anyio.to_thread.run_sync( cm.__exit__, type(e), e, None, limiter=exit_limiter ) ) if not ok:
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Mon Dec 25 17:57:35 GMT 2023 - 1.4K bytes - Viewed (0)