Search Options

Results per page
Sort
Preferred Languages
Advance

Results 701 - 710 of 896 for Streams (0.68 sec)

  1. android/guava/src/com/google/common/hash/MessageDigestHashFunction.java

        private static final long serialVersionUID = 0;
      }
    
      Object writeReplace() {
        return new SerializedForm(prototype.getAlgorithm(), bytes, toString);
      }
    
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /** Hasher that updates a message digest. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/hash/PrimitiveSink.java

    import com.google.common.annotations.Beta;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.nio.ByteBuffer;
    import java.nio.charset.Charset;
    
    /**
     * An object which can receive a stream of primitive values.
     *
     * @author Kevin Bourrillion
     * @since 12.0 (in 11.0 as {@code Sink})
     */
    @Beta
    public interface PrimitiveSink {
      /**
       * Puts a byte into this sink.
       *
       * @param b a byte
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt

        if (showHeaders) {
          println(StatusLine.get(response))
          val headers = response.headers
          for ((name, value) in headers) {
            println("$name: $value")
          }
          println()
        }
    
        // Stream the response to the System.out as it is returned from the server.
        val out = System.out.sink()
        val source = response.body.source()
        while (!source.exhausted()) {
          out.write(source.buffer, source.buffer.size)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/plugin/internal/DeprecatedCoreExpressionValidator.java

                ExpressionEvaluator expressionEvaluator) {
            if (mojoDescriptor.getParameters() == null) {
                return;
            }
    
            mojoDescriptor.getParameters().stream()
                    .filter(this::isDeprecated)
                    .map(this::formatParameter)
                    .forEach(m -> pluginValidationManager.reportPluginMojoValidationIssue(
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/ImmutableEnumSet.java

      @Override
      @J2ktIncompatible // serialization
      Object writeReplace() {
        return new EnumSerializedForm<E>(delegate);
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /*
       * This class is used to serialize ImmutableEnumSet instances.
       */
      @J2ktIncompatible // serialization
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/FrameLogTest.kt

    import okhttp3.internal.http2.Http2.formatFlags
    import okhttp3.internal.http2.Http2.frameLog
    import okhttp3.internal.http2.Http2.frameLogWindowUpdate
    import org.junit.jupiter.api.Test
    
    class FrameLogTest {
      /** Real stream traffic applied to the log format.  */
      @Test
      fun exampleStream() {
        assertThat(frameLog(false, 0, 5, TYPE_SETTINGS, FLAG_NONE))
          .isEqualTo(">> 0x00000000     5 SETTINGS      ")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/hash/MessageDigestHashFunction.java

        private static final long serialVersionUID = 0;
      }
    
      Object writeReplace() {
        return new SerializedForm(prototype.getAlgorithm(), bytes, toString);
      }
    
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /** Hasher that updates a message digest. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  8. compat/maven-model/src/main/java/org/apache/maven/model/io/xpp3/MavenXpp3Reader.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.model.io.xpp3;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    
    import org.apache.maven.model.InputSource;
    import org.apache.maven.model.Model;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/PomInlinerTransformer.java

     * under the License.
     */
    package org.apache.maven.internal.transformation.impl;
    
    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.UncheckedIOException;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.ArrayList;
    import java.util.Collection;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 20:01:00 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/props/MavenPropertiesLoader.java

                            tokStarted = true;
                            tokBuf.append(tok.trim());
                            break;
                    }
                }
    
                // Handle case where end of token stream and
                // still got data
                if ((!exit) && (tokStarted)) {
                    retVal = tokBuf.toString();
                }
            }
    
            return optional ? "?" + retVal : retVal;
        }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jan 24 17:29:44 UTC 2025
    - 6.4K bytes
    - Viewed (0)
Back to top