- Sort Score
- Result 10 results
- Languages All
Results 741 - 750 of 849 for upstream (0.09 sec)
-
cmd/erasure-sets.go
return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts) } // Destination is not versioned and source version ID is empty // perform an in-place update. if !dstOpts.Versioned && srcOpts.VersionID == "" { srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
src/main/java/jcifs/smb1/Config.java
if( log.level > 1 ) log.println( "SecurityException: jcifs.smb1 will ignore System properties" ); } } /** * Load the <code>Config</code> with properties from the stream * <code>in</code> from a <code>Properties</code> file. */ public static void load( InputStream in ) throws IOException { if( in != null ) { prp.load( in ); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 11.3K bytes - Viewed (0) -
docs/features/https.md
for ((name, value) in response.headers) { println("$name: $value") } println(response.body!!.string()) } } /** * Returns an input stream containing one or more certificate PEM files. This implementation just * embeds the PEM files in Java strings; most applications will instead read this from a resource * file that gets bundled with the application.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Dec 24 00:16:30 UTC 2022 - 10.5K bytes - Viewed (0) -
internal/s3select/csv/reader.go
bufferPool sync.Pool // pool of []byte objects for input csvDstPool sync.Pool // pool of [][]string used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 8.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) } /** * Regression test for an edge case where closing response body in the HTTP engine doesn't release * the corresponding stream allocation. This test keeps those response bodies alive and reads * them after the redirect has completed. This forces a connection to not be reused where it would * be otherwise. * *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 12.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableTableTest.java
import com.google.common.annotations.J2ktIncompatible; import com.google.common.collect.Table.Cell; import com.google.common.testing.CollectorTester; import com.google.common.testing.SerializableTester; import java.util.stream.Collector; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests common methods in {@link ImmutableTable} * * @author Gregory Kick */ @GwtCompatible(emulated = true)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 18.5K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/BaseParser.java
* KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.maven.cling.invoker; import javax.xml.stream.XMLStreamException; import java.io.IOException; import java.io.InputStream; import java.io.PrintWriter; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/BaseEncodingTest.java
fail("Expected DecodingException"); } catch (DecodingException expected) { // Don't assert on the expectedMessage; the messages for exceptions thrown from the // decoding stream may differ from the messages for the decode methods. } catch (IOException e) { fail("Expected DecodingException but got: " + e); } } };
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 16:27:30 UTC 2024 - 24.6K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java
MavenSession session = legacySupport.getSession(); if (session != null) { pomRepositories = session.getProjects().stream() .filter(p -> artifact.equals(p.getArtifact())) .map(MavenProject::getRemoteArtifactRepositories) .findFirst()
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 30.3K bytes - Viewed (0) -
cmd/encryption-v1_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 24 04:17:08 UTC 2022 - 19.9K bytes - Viewed (0)