- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 831 for Streams (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
check(!isLocallyInitiated) { "locally-initiated streams shouldn't have headers yet" } headersQueue += headers } else { check(isLocallyInitiated) { "remotely-initiated streams should have headers" } } } /** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableListMultimap.java
@J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); Serialization.writeMultimap(this, stream); } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); int keyCount = stream.readInt(); if (keyCount < 0) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketHandler.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package mockwebserver3 import okio.Socket /** * Handles a call's request and response streams directly. Use this instead of [MockResponseBody] to * begin sending response data before all request data has been received. * * See [okhttp3.RequestBody.isDuplex]. */ public interface SocketHandler {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 940 bytes - Viewed (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Options.java
* @return an {@link Optional} containing the file path, or empty if not set */ @Nonnull Optional<String> logFile(); /** * Returns whether raw streams should be logged. * * @return a boolean indicating whether raw streams should be logged */ @Nonnull Optional<Boolean> rawStreams(); /** * Returns the color setting for console output. *
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Mon Jan 13 16:14:35 UTC 2025 - 6.5K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbPipeHandleInternalTest.java
verify(tree, times(2)).acquire(); } @Test @DisplayName("getInput/getOutput return cached streams when open; throw when closed") void getInputOutput_caching_and_closed() throws Exception { // Arrange: minimal stubs so stream construction works SmbPipeHandleImpl handle = newHandleWithBasicStubs(0, "\\\\pipe\\\\foo"); when(pipe.ensureTreeConnected()).thenReturn(tree);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 16.7K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
if err := stream.Skip(); err != nil { return fmt.Errorf("stream skip: %w", err) } continue } return fmt.Errorf("next stream: %w", err) } if strings.Contains(stream.Name, "..") || !utf8.ValidString(stream.Name) { return fmt.Errorf("invalid stream name: %q", stream.Name) } dst := filepath.Join(extractDir, stream.Name) os.Mkdir(extractDir, 0o755) w, err := os.Create(dst)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 17 17:09:42 UTC 2025 - 2.3K bytes - Viewed (0) -
guava/src/com/google/common/io/CharStreams.java
break; } } return processor.getResult(); } /** * Reads and discards data from the given {@code Readable} until the end of the stream is reached. * Returns the total number of chars read. Does not close the stream. * * @since 20.0 */ @CanIgnoreReturnValue public static long exhaust(Readable readable) throws IOException { long total = 0; long read;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 30 17:25:01 UTC 2025 - 10.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeInputStream.java
protected synchronized SmbFileHandleImpl ensureOpen() throws CIFSException { return this.handle.ensureOpen(); } /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server.
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
} return Integer.toString(n); } }; thread.start(); } /** * This request body makes it possible for another thread to stream data to the uploading request. * This is potentially useful for posting live event streams like video capture. Callers should * write to {@code sink()} and close it to complete the post. */ static final class PipeBody extends RequestBody {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jul 06 03:18:15 UTC 2018 - 3.1K bytes - Viewed (0) -
android/guava/src/com/google/common/math/StatsAccumulator.java
import static java.lang.Double.isNaN; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.util.Iterator; import java.util.stream.DoubleStream; import java.util.stream.IntStream; import java.util.stream.LongStream; /** * A mutable object which accumulates double values and tracks some basic statistics over all the
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 16:36:11 UTC 2025 - 15.8K bytes - Viewed (0)