Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 43 for upstream (0.06 sec)

  1. guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns a {@link Stream} containing the elements of the first stream, followed by the elements
       * of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Streams.java

      }
    
      /**
       * Returns a {@link Stream} containing the elements of the first stream, followed by the elements
       * of the second stream, and so on.
       *
       * <p>This is equivalent to {@code Stream.of(streams).flatMap(stream -> stream)}, but the returned
       * stream may perform better.
       *
       * @see Stream#concat(Stream, Stream)
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/CharSource.java

      }
    
      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionStreamTester.java

      /*
       * We're not really testing the implementation of Stream, only that we're getting a Stream
       * that corresponds to the expected elements.
       */
    
      @CollectionFeature.Require(absent = KNOWN_ORDER)
      public void testStreamToArrayUnknownOrder() {
        Helpers.assertEqualIgnoringOrder(getSampleElements(), asList(collection.stream().toArray()));
      }
    
      @CollectionFeature.Require(KNOWN_ORDER)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:51:04 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/ImmutableBiMapFloodingTest.java

    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.stream.Stream;
    
    @GwtIncompatible
    public class ImmutableBiMapFloodingTest extends AbstractHashFloodingTest<BiMap<Object, Object>> {
      public ImmutableBiMapFloodingTest() {
        super(
            EnumSet.allOf(ConstructionPathway.class).stream()
                .flatMap(
                    path ->
                        Stream.<Construction<BiMap<Object, Object>>>of(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/CharSink.java

    import java.io.Reader;
    import java.io.Writer;
    import java.nio.charset.Charset;
    import java.util.Iterator;
    import java.util.stream.Stream;
    
    /**
     * A destination to which characters can be written, such as a text file. Unlike a {@link Writer}, a
     * {@code CharSink} is not an open, stateful stream that can be written to and closed. Instead, it
     * is an immutable <i>supplier</i> of {@code Writer} instances.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/CharSinkTest.java

        sink.writeLines(ImmutableList.of("foo", "bar", "baz").stream());
        String separator = LINE_SEPARATOR.value();
        assertEquals("foo" + separator + "bar" + separator + "baz" + separator, sink.getString());
      }
    
      public void testWriteLines_stream_separator() throws IOException {
        sink.writeLines(ImmutableList.of("foo", "bar", "baz").stream(), "!");
        assertEquals("foo!bar!baz!", sink.getString());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Ordering.java

     * well.
     *
     * <h3>Java 8+ users</h3>
     *
     * <p>If you are using Java 8+, this class is now obsolete. Most of its functionality is now
     * provided by {@link java.util.stream.Stream Stream} and by {@link Comparator} itself, and the rest
     * can now be found as static methods in our new {@link Comparators} class. See each method below
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/CollectSpliteratorsTest.java

    import com.google.common.base.Ascii;
    import com.google.common.collect.testing.SpliteratorTester;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Spliterator;
    import java.util.stream.DoubleStream;
    import java.util.stream.IntStream;
    import java.util.stream.LongStream;
    import junit.framework.TestCase;
    
    /** Tests for {@code CollectSpliterators}. */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/CharSourceTest.java

    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.Reader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.util.EnumSet;
    import java.util.List;
    import java.util.stream.Stream;
    import junit.framework.TestSuite;
    
    /**
     * Tests for the default implementations of {@code CharSource} methods.
     *
     * @author Colin Decker
     */
    public class CharSourceTest extends IoTestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top