- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,151 for awaitable (1.75 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem_test.cc
tf_writable_file::Append(file, content + 4, 4, status_); ASSERT_TF_OK(status_); length = tf_writable_file::Tell(file, status_); ASSERT_EQ(length, 8); ASSERT_TF_OK(status_); tf_writable_file::Flush(file, status_); ASSERT_TF_OK(status_); ASSERT_TRUE( CompareWithServer(filepath, 0, 8, &gcs_file->gcs_client, status_)); tf_writable_file::Close(file, status_);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 12:04:23 GMT 2020 - 24.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/TestInputStream.java
public long skip(long n) throws IOException { throwIf(closed); throwIf(SKIP_THROWS); return in.skip(n); } @Override public int available() throws IOException { throwIf(closed); return options.contains(TestOption.AVAILABLE_ALWAYS_ZERO) ? 0 : in.available(); } @Override public void close() throws IOException { closed = true; throwIf(CLOSE_THROWS); in.close(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestInputStream.java
public long skip(long n) throws IOException { throwIf(closed); throwIf(SKIP_THROWS); return in.skip(n); } @Override public int available() throws IOException { throwIf(closed); return options.contains(TestOption.AVAILABLE_ALWAYS_ZERO) ? 0 : in.available(); } @Override public void close() throws IOException { closed = true; throwIf(CLOSE_THROWS); in.close(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
) const ( memTotal = "total" memUsed = "used" memFree = "free" memBuffers = "buffers" memCache = "cache" memUsedPerc = "used_perc" memShared = "shared" memAvailable = "available" ) var ( memTotalMD = NewGaugeMD(memTotal, "Total memory on the node") memUsedMD = NewGaugeMD(memUsed, "Used memory on the node")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:10:25 GMT 2024 - 2.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransPeekNamedPipeResponse.java
static final int STATUS_DISCONNECTED = 1; static final int STATUS_LISTENING = 2; static final int STATUS_CONNECTION_OK = 3; static final int STATUS_SERVER_END_CLOSED = 4; int status, available; TransPeekNamedPipeResponse( SmbNamedPipe pipe ) { this.pipe = pipe; } int writeSetupWireFormat( byte[] dst, int dstIndex ) { return 0; }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 2.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
assertEquals("Cause should be available.", exception, handler.exception); assertEquals("EventBus should be available.", eventBus, handler.context.getEventBus()); assertEquals("Event should be available.", EVENT, handler.context.getEvent()); assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber()); assertEquals( "Method should be available.",
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
assertEquals("Cause should be available.", exception, handler.exception); assertEquals("EventBus should be available.", eventBus, handler.context.getEventBus()); assertEquals("Event should be available.", EVENT, handler.context.getEvent()); assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber()); assertEquals( "Method should be available.",
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v2beta2/generated.proto
// current scale target (e.g. CPU or memory). The values will be averaged // together before being compared to the target. Such metrics are built in to // Kubernetes, and have special scaling options on top of those available to // normal per-pod metrics using the "pods" source. Only one "target" type // should be set. message ContainerResourceMetricSource { // name is the name of the resource in question. optional string name = 1;
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v2beta1/generated.proto
// current scale target (e.g. CPU or memory). The values will be averaged // together before being compared to the target. Such metrics are built in to // Kubernetes, and have special scaling options on top of those available to // normal per-pod metrics using the "pods" source. Only one "target" type // should be set. message ContainerResourceMetricSource { // name is the name of the resource in question. optional string name = 1;
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 21.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* 2. The client thread is interrupted sometime before the result would be * available. * 3. We expect the client's get() to throw an InterruptedException. * 4. We expect the client thread's interrupt state to be false. * 5. The client thread again makes a blocking call to get(). * 6. Now the result becomes available. * 7. We expect get() to return this result.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0)