Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,736 for read (0.04 sec)

  1. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

      private val countingSource: CountingSource = CountingSource(source)
      private val source: BufferedSource = countingSource.buffer()
    
      /** Total bytes read thus far. */
      private val byteCount: Long
        get() = countingSource.bytesRead - source.buffer.size
    
      /** How many bytes to read before [peekHeader] should return false, or -1L for no limit. */
      private var limit = -1L
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. 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)
  3. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java

        @Override
        public Settings read(File input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (InputStream in = Files.newInputStream(input.toPath())) {
                InputSource source = new InputSource(input.toString());
                return new Settings(new SettingsStaxReader().read(in, isStrict(options), source));
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

            reader.setScrollSize(1000);
            int count = 0;
            Set<String> valueSet = Collections.synchronizedSet(new HashSet<>());
            Map<String, Object> source;
            while ((source = reader.read()) != null) {
                assertTrue(source.get("field1").toString().startsWith("test"));
                valueSet.add(source.get("field1").toString());
                count++;
            }
            assertEquals(num, count);
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. internal/lsync/lrwmutex_test.go

    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.RUnlock()
    		// fmt.Println("1st read lock released, waiting...")
    	}()
    
    	go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. tests/test_tutorial/test_sql_databases/test_tutorial001.py

                    "id": 999,
                    "name": "Dead Pond",
                    "age": 30,
                    "secret_name": "Dive Wilson",
                },
            )
            assert response.status_code == 200, response.text
            assert response.json() == snapshot(
                {"age": 30, "secret_name": "Dive Wilson", "id": 999, "name": "Dead Pond"}
            )
    
            # Read a hero
            hero_id = response.json()["id"]
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 09 19:44:42 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  7. .github/workflows/check-bad-merge.yml

            run: |
              git log --pretty=format:"%H" ${{ github.event.pull_request.base.sha }}..${{ github.event.pull_request.head.sha }} > pr_commits.txt
          - name: Check PR commits
            id: run_check
            run: |
              groovy .github/workflows/CheckBadMerge.groovy $(<pr_commits.txt) > output.txt 2>&1
          - name: Read output file
            id: read_output
            if: ${{ always() }}
            run: |
              cat output.txt
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Oct 11 18:32:33 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/pac/ASN1Util.java

            int ftag = in.read();
            int tag = readTagNumber(in, ftag);
            if ( tag != expectTag ) {
                throw new IOException("Unexpected tag " + tag);
            }
            int length = readLength(in, limit, false);
            byte[] content = new byte[length];
            in.read(content);
            return content;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  9. internal/s3select/progress.go

    	closed   bool
    }
    
    func (pr *progressReader) Read(p []byte) (n int, err error) {
    	// This ensures that Close will block until Read has completed.
    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    	}
    	return pr.processedReader.Read(p)
    }
    
    func (pr *progressReader) Close() error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/DefaultToolchainsReader.java

        @Override
        public PersistedToolchains read(File input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (InputStream in = Files.newInputStream(input.toPath())) {
                InputSource source = new InputSource(input.toString());
                return new PersistedToolchains(new MavenToolchainsStaxReader().read(in, isStrict(options), source));
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top