Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 1,264 for Streams (0.05 seconds)

  1. guava-tests/test/com/google/common/io/TestStreamSupplier.java

    /**
     * Interface for a supplier of streams that can report whether a stream was opened and whether that
     * stream was closed. Intended for use in a test where only a single stream should be opened and
     * possibly closed.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public interface TestStreamSupplier {
    
      /** Returns whether or not a new stream was opened. */
      boolean wasStreamOpened();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  2. 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 {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jul 06 03:18:15 GMT 2018
    - 3.1K bytes
    - Click Count (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenUpCling.java

            return new MavenUpCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenCling.java

            return new MavenCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

    import okio.buffer
    
    /**
     * Adapts a [java.net.Socket] to MockWebServer's needs.
     *
     * Note that [asOkioSocket] returns a socket that closes the underlying [java.net.Socket] when both
     * of its component streams are closed. This class takes advantage of that.
     */
    internal class MockWebServerSocket(
      val javaNetSocket: Socket,
    ) : Closeable,
      BufferedSocket {
      private val delegate = javaNetSocket.asOkioSocket()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenEncCling.java

            return new MavenEncCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenShellCling.java

            return new MavenShellCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. build-tools-internal/src/main/resources/changelog-schema.json

                "Cluster Coordination",
                "Discovery-Plugins",
                "Distributed",
                "EQL",
                "Engine",
                "FIPS",
                "Features/CAT APIs",
                "Features/Data streams",
                "Features/Features",
                "Features/ILM+SLM",
                "Features/Indices APIs",
                "Features/Ingest",
                "Features/Java High Level REST Client",
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 06:25:29 GMT 2021
    - 5K bytes
    - Click Count (0)
  9. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 16:36:11 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/math/Stats.java

    import java.io.Serializable;
    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    import java.util.Iterator;
    import java.util.Objects;
    import java.util.stream.Collector;
    import java.util.stream.DoubleStream;
    import java.util.stream.IntStream;
    import java.util.stream.LongStream;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A bundle of statistical summary values -- sum, count, mean/average, min and max, and several
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 25.1K bytes
    - Click Count (0)
Back to Top