Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 625 for streams (0.04 seconds)

  1. impl/maven-cli/src/test/java/org/apache/maven/cling/transfer/FileSizeFormatTest.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.transfer;
    
    import java.util.Locale;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.services.MessageBuilder;
    import org.apache.maven.cling.transfer.FileSizeFormat.ScaleUnit;
    import org.apache.maven.impl.DefaultMessageBuilder;
    import org.junit.jupiter.api.AfterAll;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 14.9K bytes
    - Click Count (0)
  2. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

          if (file.isDirectory) {
            serveDirectory(stream, file.listFiles()!!)
          } else if (file.exists()) {
            serveFile(stream, file)
          } else {
            send404(stream, path)
          }
        } catch (e: IOException) {
          Platform.get().log("Failure serving Http2Stream: " + e.message, Platform.INFO, null)
        }
      }
    
      private fun send404(
        stream: Http2Stream,
        path: String,
      ) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/ByteSink.java

       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
       * delegate to {@link #openStream()} when the stream returned by that method does not benefit from
       * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new,
       * independent stream each time it is called.
       *
       * <p>The caller is responsible for ensuring that the returned stream is closed.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 4.9K bytes
    - Click Count (0)
  4. guava/src/com/google/common/io/ByteSink.java

       * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
       * delegate to {@link #openStream()} when the stream returned by that method does not benefit from
       * additional buffering (for example, a {@code ByteArrayOutputStream}). This method returns a new,
       * independent stream each time it is called.
       *
       * <p>The caller is responsible for ensuring that the returned stream is closed.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 4.9K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/PluginLifecycle.java

                            return Collections.emptyList();
                        }
    
                        @Override
                        public Stream<Phase> allPhases() {
                            return Stream.concat(Stream.of(this), phases().stream().flatMap(Phase::allPhases));
                        }
                    })
                    .collect(Collectors.toList());
        }
    
        @Override
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/Serialization.java

          Map<K, V> map, ObjectOutputStream stream) throws IOException {
        stream.writeInt(map.size());
        for (Map.Entry<K, V> entry : map.entrySet()) {
          stream.writeObject(entry.getKey());
          stream.writeObject(entry.getValue());
        }
      }
    
      /**
       * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap}
       * for the data format.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Dec 09 15:58:48 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/PushObserver.kt

     * correlated by stream ID.
     *
     *  * [onRequest]
     *  * [onHeaders] (unless canceled)
     *  * [onData] (optional sequence of data frames)
     *
     * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple
     * connections should expect repetition of stream IDs.
     *
     * Return true to request cancellation of a pushed stream.  Note that this does not guarantee
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  8. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/relocation/UserPropertiesArtifactRelocationSource.java

    import javax.inject.Named;
    import javax.inject.Singleton;
    
    import java.util.Arrays;
    import java.util.List;
    import java.util.Objects;
    import java.util.function.Predicate;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.model.Model;
    import org.apache.maven.repository.internal.MavenArtifactRelocationSource;
    import org.apache.maven.repository.internal.RelocatedArtifact;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 9K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

      /** Returns the trailers after the HTTP response if they're ready. May be empty. */
      @Throws(IOException::class)
      fun peekTrailers(): Headers?
    
      /**
       * Cancel this stream. Resources held by this stream will be cleaned up, though not synchronously.
       * That may happen later by the connection pool thread.
       */
      fun cancel()
    
      /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/collect/ImmutableBiMapFloodingTest.java

    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.stream.Stream;
    import org.jspecify.annotations.NullUnmarked;
    
    @GwtIncompatible
    @NullUnmarked
    public class ImmutableBiMapFloodingTest extends AbstractHashFloodingTest<BiMap<Object, Object>> {
      public ImmutableBiMapFloodingTest() {
        super(
            EnumSet.allOf(ConstructionPathway.class).stream()
                .flatMap(
                    path ->
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 28 19:11:14 GMT 2025
    - 4.5K bytes
    - Click Count (0)
Back to Top