- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Peeker (0.76 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/index/suffixarray/sais2.go
// (from text_64), and saTmp will typically be much larger, so we'll use saTmp. // When deeper recursions come back to recurse_64, now oldTmp is // the saTmp from the top-most recursion, it is typically larger than // the current saTmp (because the current sa gets smaller and smaller // as the recursion gets deeper), and we keep reusing that top-most // large saTmp instead of the offered smaller ones. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 23:57:18 UTC 2024 - 52.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
// not been stored to yet. llvm::SmallDenseMap<Value, TF::AssignVariableOp> resource_handle_to_last_store_op; // Only iterate through ops directly in the block as we can't handle ops // nested deeper in regions. for (Operation& op : llvm::make_early_inc_range(*block)) { if (auto read_variable_op = dyn_cast<TF::ReadVariableOp>(&op)) { Value resource = read_variable_op.getResource();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0) -
src/net/http/transport.go
} func (pc *persistConn) readLoopPeekFailLocked(peekErr error) { if pc.closed != nil { return } if n := pc.br.Buffered(); n > 0 { buf, _ := pc.br.Peek(n) if is408Message(buf) { pc.closeLocked(errServerClosedIdle) return } else { log.Printf("Unsolicited response received on idle HTTP channel starting with %q; err=%v", buf, peekErr) } } if peekErr == io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 03 14:46:32 UTC 2024 - 50.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterators.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 03 14:46:32 UTC 2024 - 50.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
var resource, subresource string switch parts := strings.Split(path, "/"); len(parts) { case 2: resource, subresource = parts[0], parts[1] case 1: resource = parts[0] default: // TODO: support deeper paths return "", "", fmt.Errorf("api_installer allows only one or two segment paths (resource or resource/subresource)") } return resource, subresource, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go
} } } // If any schema related validation errors have been found at this level or deeper, skip CEL expression validation. // Invalid OpenAPISchemas are not always possible to convert into valid CEL DeclTypes, and can lead to CEL
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 82.6K bytes - Viewed (0)