Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 831 for Streams (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top