- Sort Score
- Num 10 results
- Language All
Results 671 - 680 of 832 for Streams (0.09 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/deadlineconn/deadlineconn.go
import ( "context" "net" "sync" "sync/atomic" "time" ) // updateInterval is the minimum time between deadline updates. const updateInterval = 250 * time.Millisecond // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Dec 02 13:21:17 GMT 2024 - 5.1K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
*/ package org.codelibs.fess.crawler; import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.stream.Collectors; import org.codelibs.core.io.CloseableUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.lang.SystemUtil; import org.codelibs.fess.crawler.builder.RequestDataBuilder;
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Aug 07 02:55:08 GMT 2025 - 20.4K bytes - Click Count (0) -
src/test/java/jcifs/http/NetworkExplorerTest.java
protected void doFile(HttpServletRequest req, HttpServletResponse resp, SmbFile file) throws IOException { // Mock implementation resp.setContentType("application/octet-stream"); resp.setHeader("Content-Length", "100"); } }; networkExplorer.init(servletConfig); // Setup authentication
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 21 04:51:33 GMT 2025 - 21.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
*/ @PreDestroy public void destroy() { if (logger.isDebugEnabled()) { logger.debug("cache stats: {}", statsCache.stats()); } statsCache.asMap().entrySet().stream().forEach(e -> { final StatsObject data = e.getValue(); final Long begin = data.remove(BEGIN_KEY); if (begin != null) { printStats(e.getKey(), data, begin, false);Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 17.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
int index = roundRobinIndex.getAndIncrement() % channels.size(); return channels.get(index); case LEAST_CONNECTIONS: return channels.stream() .min((c1, c2) -> Integer.compare(c1.getActiveConnections(), c2.getActiveConnections())) .orElse(channels.get(0)); case RANDOM:
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
docs/es/docs/advanced/custom-response.md
# Response Personalizado - HTML, Stream, Archivo, otros { #custom-response-html-stream-file-others } Por defecto, **FastAPI** devolverá los responses usando `JSONResponse`. Puedes sobrescribirlo devolviendo un `Response` directamente como se ve en [Devolver una Response directamente](response-directly.md){.internal-link target=_blank}.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 13.2K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/SitemapVideo.java
/** * A space-delimited list of platforms where the video may or may not be played. */ private String platform; /** * Indicates whether the video is a live stream. */ private String live; /** * Creates a new SitemapVideo instance. */ public SitemapVideo() { // Default constructor } /**Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 13 13:34:36 GMT 2025 - 8.9K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/SourceMetaDataVisitor.java
@Override public void visit(CompilationUnit compilationUnit, ClassMetaDataRepository<ClassMetaData> repository) { super.visit(compilationUnit, repository); compilationUnit.getImports().stream() .filter(anImport -> !anImport.isStatic()) .map(anImport -> anImport.getNameAsString() + (anImport.isAsterisk() ? ".*" : ""))Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Mon Aug 19 15:07:24 GMT 2024 - 11.8K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.artifact.repository.metadata; import javax.xml.stream.XMLStreamException; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.nio.file.Files; import org.apache.maven.artifact.Artifact;
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 7.2K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/StrategyOrchestrator.java
logUpgradeOptions(context); UpgradeResult overallResult = UpgradeResult.empty(); // Filter and execute applicable strategies List<UpgradeStrategy> applicableStrategies = strategies.stream() .filter(strategy -> strategy.isApplicable(context)) .toList(); if (applicableStrategies.isEmpty()) { context.warning("No applicable upgrade strategies found");
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 18:03:26 GMT 2025 - 7K bytes - Click Count (0)