- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 468 for STREAM (3.09 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} } /** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ElevateWordService.java
*/ package org.codelibs.fess.app.service; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.io.IOException; import java.io.Reader; import java.io.Writer; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.5K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device.cc
bool* stream_was_changed) { if (!(*stream) || !(*stream)->ok()) { xla::StreamPool::Ptr ptr; TF_ASSIGN_OR_RETURN(ptr, backend->BorrowStream(device_ordinal_)); *stream = std::shared_ptr<se::Stream>(std::move(ptr)); VLOG(1) << "XlaDevice " << this << " new " << name << " stream=" << (*stream);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 21:05:42 UTC 2024 - 24.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/relatedquery/AdminRelatedqueryAction.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.admin.relatedquery; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/labeltype/AdminLabeltypeAction.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.admin.labeltype; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/QueryFieldConfig.java
*/ package org.codelibs.fess.query; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.function.Consumer; import java.util.stream.Stream; import javax.annotation.PostConstruct;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java
.stream(new ByteArrayInputStream("file1".getBytes()), 5, -1).contentType("application/octet-stream").build()); minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object("dir1/file2.txt") .stream(new ByteArrayInputStream("file2".getBytes()), 5, -1).contentType("application/octet-stream").build());
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 13.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultLifecycleRegistry.java
@Override public Iterator<Lifecycle> iterator() { return stream().toList().iterator(); } @Override public Stream<Lifecycle> stream() { return providers.stream().map(ExtensibleEnumProvider::provides).flatMap(Collection::stream); } @Override public Optional<Lifecycle> lookup(String id) { return stream().filter(lf -> Objects.equals(id, lf.id())).findAny(); } @Named
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed May 22 13:45:13 UTC 2024 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
split(fessConfig.getSuggestFieldContents(), ",") .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add)); split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add)); split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(roleFieldNameSet::add));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
case v1.StreamTypeStdout: replyChan <- struct{}{} ctx.stdoutStream = stream case v1.StreamTypeStdin: replyChan <- struct{}{} ctx.stdinStream = stream case v1.StreamTypeStderr: replyChan <- struct{}{} ctx.stderrStream = stream case v1.StreamTypeResize: replyChan <- struct{}{} ctx.resizeStream = stream default: // add other stream ...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0)