- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 878 for Stream (0.08 sec)
-
cmd/object-api-utils.go
var dopts []s2.ReaderOption if off > 0 || decOff > 0 { // We are not starting at the beginning, so ignore stream identifiers. dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier()) } s2Reader := s2.NewReader(inputReader, dopts...) // Apply the skipLen and limit on the decompressed stream. if decOff > 0 { if err = s2Reader.Skip(decOff); err != nil { // Call the cleanup funcs
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 37.1K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
when explicitly forbidden. * Fix: Throw a `SSLPeerUnverifiedException` when host verification fails. * Fix: MockWebServer explicitly closes sockets. (On some Android releases, closing the input stream and output stream of a socket is not sufficient. * Fix: Buffer outgoing HTTP/2 frames to limit how many outgoing frames are created. * Fix: Avoid crashing when cache writing fails due to a full disk.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 18:31:45 UTC 2024 - 5.7K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix: Support Shoutcast HTTP responses like `ICY 200 OK`. * Fix: Don't unzip if there isn't a response body. * Fix: Don't leak gzip streams on redirects. * Fix: Don't do DNS lookups on invalid hosts. * Fix: Exhaust the underlying stream when reading gzip streams. * Fix: Support the `PATCH` method. * Fix: Support request bodies on `DELETE` method. * Fix: Drop the `okhttp-protocols` module.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java
saveLayout(writer, typed); } /** * Store a properties into a output stream, preserving comments, special character, etc. * This method is mainly to be compatible with the java.util.Properties class. * * @param os an output stream. * @param comment this parameter is ignored as this Properties * @throws IOException If storing fails */
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeMultiset.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(elementSet().comparator()); Serialization.writeMultiset(this, stream); } @J2ktIncompatible @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 34.5K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
// values within the array are emitted to the stream, then the array // containing those values is emitted. func (d *Decoder) Recursive() *Decoder { d.emitRecursive = true return d } // Stream begins decoding from the underlying reader and returns a // streaming MetaValue channel for JSON values at the configured emitDepth. func (d *Decoder) Stream() chan *MetaValue { go d.decode() return d.metaCh }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/HtmlTransformer.java
import java.util.ArrayList; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Stream; import javax.xml.xpath.XPathException; import javax.xml.xpath.XPathNodes; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.Pair;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Oct 24 12:16:00 UTC 2024 - 19.4K bytes - Viewed (0) -
.github/workflows/mint/nginx-4-node.conf
worker_processes auto; error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 4096; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"';
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 16:52:29 UTC 2024 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java
return tags; } public List<String> getRoles() { return roles; } public SuggestItem toSuggestItem() { final String[][] readingArray = this.getReadings().stream().map(reading -> new String[] { reading }).toArray(count -> new String[count][]); return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 2.5K bytes - Viewed (0)