- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 849 for upstream (0.12 sec)
-
android/guava/src/com/google/common/io/MoreFiles.java
try (DirectoryStream<Path> stream = Files.newDirectoryStream(path)) { if (stream instanceof SecureDirectoryStream) { SecureDirectoryStream<Path> sds = (SecureDirectoryStream<Path>) stream; exceptions = deleteDirectoryContentsSecure(sds); } else { checkAllowsInsecure(path, options); exceptions = deleteDirectoryContentsInsecure(stream); } } catch (IOException e) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 16:07:00 UTC 2024 - 35K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java
getAvailableKeyMatchList().stream().forEach(keyMatch -> { try { final BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); if (logger.isDebugEnabled()) { logger.debug("Loading KeyMatch Query: {}, Size: {}", keyMatch.getQuery(), keyMatch.getMaxSize()); } getDocumentList(keyMatch).stream().map(doc -> {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
idx, length int64 } // NewDummyDataGen returns a ReadSeeker over the first `totalLength` // bytes from the infinite stream consisting of repeated // concatenations of `alphabets`. // // The skipOffset (generally = 0) can be used to skip a given number // of bytes from the beginning of the infinite stream. This is useful // to compare such streams of bytes that may be split up, because: // // Given the function: //
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 4.7K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java
*/ Model read(Reader input, Map<String, ?> options) throws IOException, ModelParseException; /** * Reads the model from the specified byte stream. The stream will be automatically closed before the method * returns. * * @param input The stream to deserialize the model from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java
final CrawlingInfoHelper crawlingInfoHelper = ComponentUtil.getCrawlingInfoHelper(); final LanguageHelper languageHelper = ComponentUtil.getLanguageHelper(); final List<Map<String, Object>> docList = body.documents.stream().map(doc -> { if (!doc.containsKey(indexFieldContentLength)) { long contentLength = 0; if (doc.get(indexFieldTitle) instanceof final String title) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Jul 25 01:48:41 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/bitrot-streaming.go
"io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/ringbuffer" ) // Calculates bitrot in chunks and writes the hash into the stream. type streamingBitrotWriter struct { iow io.WriteCloser closeWithErr func(err error) h hash.Hash shardSize int64 canClose *sync.WaitGroup byteBuf []byte }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractBiMap.java
@J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(inverse()); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Aug 24 01:40:03 UTC 2023 - 14.6K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/ProfileActivation.java
import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.function.Predicate; import static java.util.stream.Collectors.toSet; /** * Container for storing the request from the user to activate or de-activate certain profiles and optionally fail the * build if those profiles do not exist. */ public class ProfileActivation {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/bucket/versioning/DESIGN.md
`xl.meta` carries first 8 bytes an XL header which describes the current format and the format version, allowing the unmarshaller's to automatically use the right data structures to parse the subsequent content in the stream. ### v1.0 | Entry | Encoding | Content | ----------|-------------|---------------------------------------- | xlHeader | [4]byte | `'X', 'L', '2', ' '` | xlVersion | [4]byte | `'1', ' ', ' ', ' '`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jul 17 15:43:14 UTC 2022 - 5.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java
assertThat(count.get()).isEqualTo(4); } public void testStream() { ImmutableIntArray.of().stream().forEach(i -> fail()); ImmutableIntArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail()); assertThat(ImmutableIntArray.of(0, 1, 3).stream().toArray()).isEqualTo(new int[] {0, 1, 3}); } public void testSubArray() { ImmutableIntArray iia0 = ImmutableIntArray.of();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 18:05:56 UTC 2024 - 20.1K bytes - Viewed (0)