- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 378 for cancels (0.07 sec)
-
src/builtin/builtin.go
// any is an alias for interface{} and is equivalent to interface{} in all ways. type any = interface{} // comparable is an interface that is implemented by all comparable types // (booleans, numbers, strings, pointers, channels, arrays of comparable types, // structs whose fields are all comparable types). // The comparable interface may only be used as a type parameter constraint, // not as the type of a variable.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FilesTest.java
import java.io.FileNotFoundException; import java.io.IOException; import java.io.PrintWriter; import java.io.RandomAccessFile; import java.nio.ByteBuffer; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel.MapMode; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Random; import junit.framework.TestSuite; /** * Unit test for {@link Files}. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if err := healFreshDisk(ctx, z, disk); err != nil { globalBackgroundHealState.setDiskHealingStatus(disk, false) timedout := OperationTimedOut{} if !errors.Is(err, context.Canceled) && !errors.As(err, &timedout) && !errors.Is(err, errRetryHealing) { printEndpointError(disk, err, false) } return } // Only upon success pop the healed disk.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/site-replication.go
resultsMu.Unlock() return }() continue } wg.Add(1) go func() { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second) defer cancel() result := perfNetRequest( ctx, info.DeploymentID, adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf, nil, ) resultsMu.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/FilesTest.java
import java.io.FileNotFoundException; import java.io.IOException; import java.io.PrintWriter; import java.io.RandomAccessFile; import java.nio.ByteBuffer; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel.MapMode; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Random; import junit.framework.TestSuite; /** * Unit test for {@link Files}. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 22.1K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
synchronized ( this.LOCK ) { /* * Yes, there is the potential to drop packets * because we might close the socket during a * request. However the chances are slim and the * retry code should ensure the overall request * is serviced. The alternative complicates things * more than I think is worth it. */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Aug 14 14:26:22 UTC 2022 - 38.2K bytes - Viewed (0) -
guava/src/com/google/common/base/Ascii.java
* structure is not necessarily related to the processing format. * * @since 8.0 */ public static final byte ETB = 23; /** * Cancel: A control character used to indicate that the data with which it is sent is in error or * is to be disregarded. * * @since 8.0 */ public static final byte CAN = 24; /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Aug 02 13:50:22 UTC 2024 - 21.7K bytes - Viewed (0) -
cmd/server_test.go
} func (s *TestSuiteCommon) RestartTestServer(c *check) { // Shutdown. s.testServer.cancel() s.testServer.Server.Close() s.testServer.Obj.Shutdown(context.Background()) // Restart. ctx, cancel := context.WithCancel(context.Background()) s.testServer.cancel = cancel s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths) if s.secure {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 15 16:28:02 UTC 2024 - 116.3K bytes - Viewed (0) -
docs/pt/docs/async.md
Ainda, em ambas as situações, as chances são que o **FastAPI** será [ainda mais rápido](index.md#performance){.internal-link target=_blank} do que (ou ao menos comparável a) seus frameworks antecessores. ### Dependências
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 22.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val connectionClose = CountDownLatch(1) val streams = object : RealWebSocket.Streams(false, source, sink) { override fun close() = connectionClose.countDown() override fun cancel() { socket.closeQuietly() } } val webSocket = RealWebSocket( taskRunner = taskRunner, originalRequest = fancyRequest,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0)