- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,060 for readArg (0.28 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
// by before the timeout fires. func (conn *Conn) SetWriteDeadline(duration time.Duration) { conn.ws.SetWriteDeadline(time.Now().Add(duration)) //nolint:errcheck } // Open the connection and create channels for reading and writing. It returns // the selected subprotocol, a slice of channels and an error. func (conn *Conn) Open(w http.ResponseWriter, req *http.Request) (string, []io.ReadWriteCloser, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java
} } private Reader getReader(final boolean reload) throws IOException { if (reload) { if (reloadableFile == null) { throw new IllegalArgumentException("reloadableFile is null."); } return new InputStreamReader(new FileInputStream(reloadableFile), StandardCharsets.UTF_8); } Reader reader = null;
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 6.7K bytes - Viewed (0) -
tensorflow/cc/saved_model/fingerprinting_utils.h
// Uses metadata contained in `chunked_message` to hash fields within the // data accessed by the `reader` using `chunks_info`. absl::StatusOr<uint64_t> HashFields( const ::tensorflow::proto_splitter::ChunkedMessage& chunked_message, riegeli::RecordReader<riegeli::FdReader<>>& reader, const std::vector<::tensorflow::proto_splitter::ChunkInfo>& chunks_info,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Feb 20 22:19:55 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/bitrot_test.go
bw.Close() } reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10) b := make([]byte, 10) if _, err = reader.ReadAt(b, 0); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 10); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 20); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b[:5], 30); err != nil { t.Fatal(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 2.1K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
override fun fromDer(reader: DerReader): T { val peekedHeader = reader.peekHeader() if (peekedHeader == null || peekedHeader.tagClass != tagClass || peekedHeader.tag != tag) { if (isOptional) return defaultValue as T throw ProtocolException("expected $this but was $peekedHeader at $reader") } val result = reader.read(name) { codec.decode(reader) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.4K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultToolchainsXmlFactory.java
Objects.requireNonNull(request, "request"); Reader reader = request.getReader(); InputStream inputStream = request.getInputStream(); if (reader == null && inputStream == null) { throw new IllegalArgumentException("reader or inputStream must be non null"); } try { InputSource source = null;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 3.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/settings/AnalyzerSettingsTest.java
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.1K bytes - Viewed (0) -
src/cmd/trace/testdata/mktests.go
} defer f.Close() // Write out the trace. r, err := raw.NewReader(&trace) if err != nil { log.Fatalf("reading trace: %v", err) } w, err := raw.NewTextWriter(f, version.Current) for { ev, err := r.ReadEvent() if err == io.EOF { break } if err != nil { log.Fatalf("reading trace: %v", err) } if err := w.WriteEvent(ev); err != nil { log.Fatalf("writing trace: %v", err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.2K bytes - Viewed (0) -
src/encoding/csv/fuzz_test.go
result, err := r.ReadAll() if err != nil { t.Logf("reader = %#v\n", r) t.Logf("records = %v\n", records) t.Fatal(err) } // The reader turns \r\n into \n. for _, record := range records { for i, s := range record { record[i] = strings.ReplaceAll(s, "\r\n", "\n") } } // Note that the reader parses the quoted record "" as an empty string,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 01:26:13 UTC 2024 - 2.5K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultModelXmlFactory.java
Path path = request.getPath(); URL url = request.getURL(); Reader reader = request.getReader(); InputStream inputStream = request.getInputStream(); if (path == null && url == null && reader == null && inputStream == null) { throw new IllegalArgumentException("path, url, reader or inputStream must be non null"); } try { InputSource source = null;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 5.4K bytes - Viewed (0)