- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 849 for upstream (0.07 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) -
src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java
} protected QueryBuilder buildFilterQuery(final String fieldName, final List<String> words) { final BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery().minimumShouldMatch(1); words.stream().forEach(word -> boolQueryBuilder.should(QueryBuilders.termQuery(fieldName, word))); return boolQueryBuilder; }
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/https/Handler.java
/** * A <code>URLStreamHandler</code> used to provide NTLM authentication * capabilities to the default HTTPS handler. This acts as a wrapper, * handling authentication and passing control to the underlying * stream handler. */ public class Handler extends jcifs.smb1.http.Handler { /** * The default HTTPS port (<code>443</code>). */ public static final int DEFAULT_HTTPS_PORT = 443; /**
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 1.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/systeminfo/AdminSysteminfoAction.java
} public static List<Map<String, String>> getFessPropItems(final FessConfig fessConfig) { final List<Map<String, String>> itemList = new ArrayList<>(); ComponentUtil.getSystemProperties().entrySet().stream().forEach(e -> { final String k = e.getKey().toString(); final String value; if (isMaskedValue(k)) { value = MASKED_VALUE; } else {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/RelatedQueryHelper.java
}); } @Override public int load() { final Map<String, Map<String, String[]>> relatedQueryMap = new HashMap<>(); getAvailableRelatedQueryList().stream().forEach(entity -> { final String key = getHostKey(entity); Map<String, String[]> map = relatedQueryMap.get(key); if (map == null) { map = new HashMap<>();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.2K bytes - Viewed (0) -
compat/maven-builder-support/src/main/java/org/apache/maven/building/StringSource.java
} @Override public String getLocation() { return location; } /** * Gets the content of this source. * * @return The underlying character stream, never {@code null}. */ public String getContent() { return content; } @Override public String toString() { return getLocation(); } @Override
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
null } } } /** * Returns a new unbuffered output stream to write the value at [index]. If the underlying * output stream encounters errors when writing to the filesystem, this edit will be aborted * when [commit] is called. The returned output stream does not throw IOExceptions. */ fun newSink(index: Int): Sink { synchronized(this@DiskLruCache) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
package jstream import ( "io" "sync/atomic" ) const ( chunk = 4095 // ~4k maxUint = ^uint(0) maxInt = int64(maxUint >> 1) nullByte = byte(0) ) type scanner struct { pos int64 // position in reader ipos int64 // internal buffer position ifill int64 // internal buffer fill end int64 buf [chunk + 1]byte // internal buffer (with a lookback size of 1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
import okio.Buffer import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 import okio.Options import okio.Source import okio.Timeout import okio.buffer /** * Reads a stream of [RFC 2046][rfc_2046] multipart body parts. Callers read parts one-at-a-time * until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. * * Typical use loops over the parts in sequence:
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/WebApiResponse.java
public WebApiResponse(final HttpServletResponse response) { super(response); } @Override public PrintWriter getWriter() throws IOException { // dummy stream return new PrintWriter(new ByteArrayOutputStream()); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 1.2K bytes - Viewed (0)