- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 956 for sekond (0.12 sec)
-
cmd/batch-expire.go
func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error { if r.NotificationCfg.Endpoint == "" { return nil } ctx, cancel := context.WithTimeout(ctx, 10*time.Second) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body) if err != nil { return err } if r.NotificationCfg.Token != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newScheduledThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 5.7K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractAcceptedApiChangesMaintenanceTaskIntegrationTest.kt
firstAcceptedApiChangesFile = projectDir.resolve("src/changes/accepted-changes/accepted-public-api-changes.json") secondAcceptedApiChangesFile = projectDir.resolve("src/changes/accepted-changes/second-accepted-public-api-changes.json") projectDir.resolve("build.gradle.kts") .writeText( """ plugins { id("gradlebuild.binary-compatibility")
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Jun 04 14:00:46 UTC 2024 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/SipHashFunction.java
/** * @param c the number of compression rounds (must be positive) * @param d the number of finalization rounds (must be positive) * @param k0 the first half of the key * @param k1 the second half of the key */ SipHashFunction(int c, int d, long k0, long k1) { checkArgument( c > 0, "The number of SipRound iterations (c=%s) during Compression must be positive.", c); checkArgument(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 5.3K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/sub-dependencies.md
``` //// It declares an optional query parameter `q` as a `str`, and then it just returns it. This is quite simple (not very useful), but will help us focus on how the sub-dependencies work. ## Second dependency, "dependable" and "dependant" Then you can create another dependency function (a "dependable") that at the same time declares a dependency of its own (so it is a "dependant" too): //// tab | Python 3.10+
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
// First CONNECT call needs a new connection. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // Second CONNECT call needs a new connection. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // GET reuses the connection from the second connect. assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } @Test
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
* the License. */ package com.google.common.util.concurrent.testing; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible; import com.google.common.util.concurrent.ListenableFuture; import java.util.concurrent.CancellationException;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
internal/http/dial_linux.go
_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_QUICKACK, 1) /// Enable keep-alive { _ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_KEEPALIVE, 1) // The time (in seconds) the connection needs to remain idle before // TCP starts sending keepalive probes _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15) // Number of probes.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AtomicLongMap.java
* {@code key} (or zero, if there is none) is passed as the first argument to {@code * accumulatorFunction}, and {@code x} is passed as the second argument. * * @since 21.0 */ @CanIgnoreReturnValue public long accumulateAndGet(K key, long x, LongBinaryOperator accumulatorFunction) { checkNotNull(accumulatorFunction);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 11.8K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
waypointName = constants.DefaultNamespaceWaypoint enrollNamespace bool overwrite bool ) const waitTimeout = 90 * time.Second func Cmd(ctx cli.Context) *cobra.Command { makeGateway := func(forApply bool) (*gateway.Gateway, error) { ns := ctx.NamespaceOrDefault(ctx.Namespace()) if ctx.Namespace() == "" && !forApply { ns = "" }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 19.6K bytes - Viewed (0)