Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,721 for read1 (0.02 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * [Call.request] is a redirect to a different address.
       *
       * Prior to OkHttp 4.3 this was incorrectly invoked when the client was ready to read headers.
       * This was misleading for tracing because it was too early.
       */
      open fun responseHeadersStart(call: Call) {
      }
    
      /**
       * Invoked immediately after receiving response headers.
       *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:03:04 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  2. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/LocalCache.java

         * at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily cause a
         * concurrent read operation to see inconsistent data. This is made easier by the nature of the
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 19:35:11 UTC 2025
    - 148.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch start() {
        checkState(!isRunning, "This stopwatch is already running.");
        isRunning = true;
        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/SuggesterResourceLoadingTest.java

            }
        }
    
        /**
         * Test that resource content is properly read using readAllBytes.
         * Verifies that the new implementation correctly reads entire resource content.
         */
        @Test
        public void testResourceReading_readAllBytesCorrectness() throws Exception {
            // Read using the new method (readAllBytes)
            String contentNew;
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         * look at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily
         * cause a concurrent read operation to see inconsistent data. This is made easier by the
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 89.9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

                dstIndex += this.andx.byteCount;
            }
    
            return dstIndex - start;
        }
    
        /**
         * Reads the AndX wire format from buffer
         * @param buffer the buffer to read from
         * @param bufferIndex the starting index
         * @return the number of bytes read
         * @throws SMBProtocolDecodingException if decoding fails
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.8K 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Aug 03 22:38:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  9. cmd/metrics-v3-system-drive.go

    	// iostat related
    	driveReadsPerSecMD = NewGaugeMD(driveReadsPerSec,
    		"Reads per second on a drive",
    		allDriveLabels...)
    	driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec,
    		"Kilobytes read per second on a drive",
    		allDriveLabels...)
    	driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
    		"Average time for read requests served on a drive",
    		allDriveLabels...)
    	driveWritesPerSecMD = NewGaugeMD(driveWritesPerSec,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            assertEquals(TransPeekNamedPipeResponse.STATUS_LISTENING, response.getStatus());
            // Middle bytes were read but not used
        }
    
        @Test
        @DisplayName("Test consecutive reads update state correctly")
        void testConsecutiveReads() {
            // First read
            byte[] buffer1 = new byte[10];
            SMBUtil.writeInt2(100, buffer1, 0);
            SMBUtil.writeInt2(0, buffer1, 2);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
Back to top