- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 459 for ACCEPT (0.18 sec)
-
platforms/core-execution/build-cache-http/src/integTest/groovy/org/gradle/caching/http/internal/HttpBuildCacheServiceTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 16:15:24 UTC 2024 - 12.4K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/KtSymbolByFirBuilder.kt
simpleFunction.returnTypeRef.accept(this) } override fun visitProperty(property: FirProperty) { property.typeParameters.forEach { it.accept(this) } property.receiverParameter?.accept(this) property.returnTypeRef.accept(this) } override fun visitReceiverParameter(receiverParameter: FirReceiverParameter) {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:43 UTC 2024 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/CollectSpliterators.java
@Override public boolean tryAdvance(Consumer<? super T> action) { return delegate.tryAdvance((IntConsumer) i -> action.accept(function.apply(i))); } @Override public void forEachRemaining(Consumer<? super T> action) { delegate.forEachRemaining((IntConsumer) i -> action.accept(function.apply(i))); } @Override @CheckForNull public Spliterator<T> trySplit() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 18:19:31 UTC 2024 - 19.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/SpliteratorTester.java
forEach(prefix, consumer); } long size = spliterator.getExactSizeIfKnown(); long[] counter = {0}; spliterator.forEachRemaining( e -> { consumer.accept(e); counter[0]++; }); if (size >= 0) { assertEquals(size, counter[0]); } } }, ALTERNATE_ADVANCE_AND_SPLIT { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 18:19:31 UTC 2024 - 11.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CacheControl.kt
internal var noTransform: Boolean = false internal var immutable: Boolean = false /** Don't accept an unvalidated cached response. */ fun noCache() = commonNoCache() /** Don't store the server's response in any cache. */ fun noStore() = commonNoStore() /** * Only accept the response if it is in the cache. If the response isn't cached, a `504
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 10K bytes - Viewed (0) -
src/net/tcpsock.go
if !l.ok() { return nil, syscall.EINVAL } c, err := l.accept() if err != nil { return nil, &OpError{Op: "accept", Net: l.fd.net, Source: nil, Addr: l.fd.laddr, Err: err} } return c, nil } // Accept implements the Accept method in the [Listener] interface; it // waits for the next call and returns a generic [Conn]. func (l *TCPListener) Accept() (Conn, error) { if !l.ok() { return nil, syscall.EINVAL }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 13.7K bytes - Viewed (0) -
src/net/net_test.go
if !testableNetwork(network) { t.Skipf("network %s is not testable on the current platform", network) } t.Parallel() handler := func(ls *localServer, ln Listener) { c, err := ln.Accept() if err != nil { t.Error(err) return } // Workaround for https://go.dev/issue/49352. // On arm64 macOS (current as of macOS 12.4),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server_test.go
}{ { name: "openmetrics minimal accept header", contentType: `application/openmetrics-text; version=0.0.1`, expected: FmtOpenMetrics_0_0_1, }, { name: "openmetrics minimal v1 accept header", contentType: `application/openmetrics-text; version=1.0.0`, expected: FmtOpenMetrics_1_0_0, }, { name: "openmetrics accept header",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 42.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/api/services/internal/DefaultBuildServicesRegistryTest.groovy
def provider = registerService("service", ServiceImpl) provider.beforeStopping(stopAction) when: buildFinished() then: 1 * stopAction.accept(provider) } def "service may be created by the stop action"() { given: def provider = registerService("service", ServiceImpl) provider.beforeStopping { provider.get() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 16.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
@Throws(IOException::class) fun missingConnectionHeader() { webServer.enqueue( MockResponse.Builder() .code(101) .setHeader("Upgrade", "websocket") .setHeader("Sec-WebSocket-Accept", "ujmZX4KXZqjwy6vi1aQFH5p4Ygk=") .build(), ) webServer.enqueue( MockResponse.Builder() .socketPolicy(SocketPolicy.DisconnectAtStart) .build(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0)