- Sort Score
- Num 10 results
- Language All
Results 761 - 770 of 1,215 for stream (0.04 seconds)
-
docs/bucket/lifecycle/README.md
``` mc admin tier add s3 source S3TIER --bucket s3bucket --prefix testprefix/ --use-aws-role ``` Once transitioned, GET or HEAD on the object will stream the content from the transitioned tier. In the event that the object needs to be restored temporarily to the local cluster, the AWS [RestoreObject API](https://docs.aws.amazon.com/AmazonS3/latest/API/API_RestoreObject.html) can be utilized.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 9.1K bytes - Click Count (0) -
internal/grid/muxserver.go
wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack) if debugPrint { fmt.Println("connected stream mux:", ack.MuxID) } }() // Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 { m.inbound = make(chan []byte, inboundCap) handlerIn = make(chan []byte, 1)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.7K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java
responseData.addMetaData(FILE_ATTRIBUTE_VIEW, aclFileAttributeView); responseData.addMetaData(FS_FILE_GROUPS, aclFileAttributeView.getAcl().stream().map(acl -> acl.principal().getName()).toArray(n -> new String[n])); return aclFileAttributeView; }
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 12:19:14 GMT 2025 - 15.1K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableRangeMap.java
import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.NoSuchElementException; import java.util.function.BiFunction; import java.util.function.Function; import java.util.stream.Collector; import org.jspecify.annotations.Nullable; /** * A {@link RangeMap} whose contents will never change, with many other important properties * detailed at {@link ImmutableCollection}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 14.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt
import kotlin.reflect.KClass import okio.IOException import okio.Timeout /** * A call is a request that has been prepared for execution. A call can be canceled. As this object * represents a single request/response pair (stream), it cannot be executed twice. */ interface Call : Cloneable { /** Returns the original request that initiated this call. */ fun request(): Request /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 6.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/PluginHelper.java
* * @return an array of repository URLs */ protected String[] getRepositories() { return split(ComponentUtil.getFessConfig().getPluginRepositories(), ",") .get(stream -> stream.map(String::trim).toArray(n -> new String[n])); } /** * Loads artifacts from a YAML-based repository. * * @param url the URL of the YAML repositoryCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Mar 04 15:19:41 GMT 2026 - 25.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableRangeMap.java
import java.io.Serializable; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.NoSuchElementException; import java.util.function.Function; import java.util.stream.Collector; import org.jspecify.annotations.Nullable; /** * A {@link RangeMap} whose contents will never change, with many other important properties * detailed at {@link ImmutableCollection}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 14.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableList.java
* ImmutableSortedSet.copyOf(elements)}; if you want a {@code List} you can use its {@code * asList()} view. * * <p><b>Java 8+ users:</b> If you want to convert a {@link java.util.stream.Stream} to a sorted * {@code ImmutableList}, use {@code stream.sorted().collect(toImmutableList())}. * * @throws NullPointerException if any element in the input is null * @since 21.0 */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 27.5K bytes - Click Count (0) -
src/main/webapp/js/chat.js
/** * Fess RAG Chat JavaScript * Enhanced with Atlassian Design System patterns */ var FessChat = (function() { 'use strict'; var config = { apiUrl: '/api/v1/chat', streamUrl: '/api/v1/chat/stream', labels: { thinking: 'Thinking...', waiting: '...', error: 'An error occurred. Please try again.', sources: 'Sources', statusReady: 'AI Assistant',Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 19 01:36:02 GMT 2026 - 30.6K bytes - Click Count (0) -
cmd/erasure-healing-common_test.go
ModTime: time.Date(2023, time.March, 15, 11, 18, 4, 989906961, time.UTC), Size: 329289, Mode: 0x0, WrittenByVersion: 0x63c77756, Metadata: map[string]string{ "content-type": "application/octet-stream", "etag": "f205307ef9f50594c4b86d9c246bee86", "x-minio-internal-erasure-upgraded": "5->6", "x-minio-internal-inline-data": "true", }, Parts: []ObjectPartInfo{ { ETag: "", Number: 1,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 22.4K bytes - Click Count (0)