Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 864 for readOp (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

        private File baseCss;
        private File releaseNotesCss;
        private File releaseNotesJavascript;
    
        public ReleaseNotesTransformer(Reader original) {
            super(original);
            this.in = new Reader() {
                Reader delegate = null;
    
                @Override
                public int read(char[] cbuf, int off, int len) throws IOException {
                    if (delegate == null) {
                        delegate = transform(original);
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 03 01:59:51 GMT 2026
    - 11.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/io/CharSequenceReader.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.io.IOException;
    import java.io.Reader;
    import java.nio.CharBuffer;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link Reader} that reads the characters in a {@link CharSequence}. Like {@code StringReader},
     * but works with any {@link CharSequence}.
     *
     * @author Colin Decker
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

          return hex.decodeHex().toResponseBody(mediaType)
        }
    
        fun exhaust(reader: Reader): String {
          val builder = StringBuilder()
          val buf = CharArray(10)
          var read: Int
          while (reader.read(buf).also { read = it } != -1) {
            builder.appendRange(buf, 0, read)
          }
          return builder.toString()
        }
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  6. cmd/postpolicyform.go

    }
    
    // parsePostPolicyForm - Parse JSON policy string into typed PostPolicyForm structure.
    func parsePostPolicyForm(r io.Reader) (PostPolicyForm, error) {
    	reader, err := sanitizePolicy(r)
    	if err != nil {
    		return PostPolicyForm{}, err
    	}
    
    	d := json.NewDecoder(reader)
    
    	// Convert po into interfaces and
    	// perform strict type conversion using reflection.
    	var rawPolicy struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Oct 23 15:10:12 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/io/TestCharSource.java

     * limitations under the License.
     */
    
    package com.google.common.io;
    
    import static java.nio.charset.StandardCharsets.UTF_8;
    
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * A char source for testing that has configurable options.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        try {
          reader!!.processNextFrame()
          receivedCloseCode == -1
        } catch (e: Exception) {
          failWebSocket(e = e)
          false
        }
    
      /**
       * Clean up and publish necessary close events when the reader is done. Invoked only by the reader
       * thread.
       */
      fun finishReader() {
        val code: Int
        val reason: String?
        val sendOnClosed: Boolean
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  9. docs/bucket/replication/delete-replication.sh

    # Test replication of delete markers and permanent deletes
    
    ./mc cp README.md myminio1/testbucket/dir/file
    ./mc cp README.md myminio1/testbucket/dir/file
    
    sleep 1s
    
    echo "=== myminio1"
    ./mc ls --versions myminio1/testbucket/dir/file
    
    echo "=== myminio2"
    ./mc ls --versions myminio2/testbucket/dir/file
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 09:42:21 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

          Header("via", ""),
          Header("www-authenticate", ""),
        )
    
      val NAME_TO_FIRST_INDEX = nameToFirstIndex()
    
      // http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12#section-3.1
      class Reader
        @JvmOverloads
        constructor(
          source: Source,
          private val headerTableSizeSetting: Int,
          private var maxDynamicTableByteCount: Int = headerTableSizeSetting,
        ) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 23.2K bytes
    - Click Count (0)
Back to Top