Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,555 for readN (0.02 sec)

  1. guava/src/com/google/common/hash/AbstractStreamingHasher.java

    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    
    /**
     * A convenience base class for implementors of {@code Hasher}; handles accumulating data until an
     * entire "chunk" (of implementation-dependent length) is ready to be hashed.
     *
     * @author Kevin Bourrillion
     * @author Dimitris Andreou
     */
    // TODO(kevinb): this class still needs some design-and-document-for-inheritance love
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 15 20:59:00 UTC 2022
    - 7.1K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyResolverResult.java

         * <p>A typical usage is to invoke this method for all dependencies having a
         * {@link DependencyScope#TEST TEST} or {@link DependencyScope#TEST_ONLY TEST_ONLY}
         * {@linkplain Dependency#getScope() scope}. An {@code --add-reads} option may need
         * to be generated for compiling and running the test classes that use such dependencies.</p>
         *
         * @param dependency path to the dependency for which to get the module name
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Sat Sep 28 09:03:24 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

            /** Stores the value lines for the currently processed property.*/
            private final List<String> valueLines;
    
            /** Stores the name of the last read property.*/
            private String propertyName;
    
            /** Stores the value of the last read property.*/
            private String propertyValue;
    
            private boolean maybeTyped;
    
            /** Stores if the properties are typed or not */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/AbstractIterator.java

        switch (state) {
          case DONE:
            return false;
          case READY:
            return true;
          default:
        }
        return tryToComputeNext();
      }
    
      private boolean tryToComputeNext() {
        state = State.FAILED; // temporary pessimism
        next = computeNext();
        if (state != State.DONE) {
          state = State.READY;
          return true;
        }
        return false;
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Mar 18 02:04:10 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        }
      }
    
      /** Read headers and process any control frames until we reach a non-control frame. */
      @Throws(IOException::class)
      private fun readUntilNonControlFrame() {
        while (!closed) {
          readHeader()
          if (!isControlFrame) {
            break
          }
          readControlFrame()
        }
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/ByteSourceTest.java

        // The stream reports no bytes... importantly, it doesn't read the byte at index 5 when it
        // should be reading the byte at index 10.
        // We could use a custom InputStream instead to make the read start at index 10, but since this
        // is a racy situation anyway, this behavior seems reasonable.
        assertEquals(-1, in.read());
      }
    
      private static class AppendableByteSource extends ByteSource {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/apps/v1beta2/generated.proto

      optional DaemonSetUpdateStrategy updateStrategy = 3;
    
      // The minimum number of seconds for which a newly created DaemonSet pod should
      // be ready without any of its container crashing, for it to be considered
      // available. Defaults to 0 (pod will be considered available as soon as it
      // is ready).
      // +optional
      optional int32 minReadySeconds = 4;
    
      // The number of old history to retain to allow rollback.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  8. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(inputStream!!.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo('D'.code)
        assertThat(inputStream.read()).isEqualTo('E'.code)
        assertThat(inputStream.read()).isEqualTo('F'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe_test.go

    							},
    						},
    					},
    					Status: corev1.PodStatus{
    						Phase: corev1.PodRunning,
    						ContainerStatuses: []corev1.ContainerStatus{
    							{
    								Name:  "istio-proxy",
    								Ready: true,
    							},
    						},
    					},
    				},
    				&corev1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "ingress",
    						Namespace: "default",
    						Labels: map[string]string{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  10. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        assertThat(inputStream.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo('D'.code)
        assertThat(inputStream.read()).isEqualTo('E'.code)
        assertThat(inputStream.read()).isEqualTo('F'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top