Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 636 for readAny (0.07 sec)

  1. android/guava/src/com/google/common/io/Files.java

        checkNotNull(file);
        checkNotNull(charset);
        return new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file), charset));
      }
    
      /**
       * Returns a new {@link ByteSource} for reading bytes from the given file.
       *
       * @since 14.0
       */
      public static ByteSource asByteSource(File file) {
        return new FileByteSource(file);
      }
    
      private static final class FileByteSource extends
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  2. cmd/storage-rest-common_gen.go

    		}
    		switch msgp.UnsafeString(field) {
    		case "id":
    			z.DiskID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DiskID")
    				return
    			}
    		case "m":
    			z.ScanMode, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ScanMode")
    				return
    			}
    		case "c":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Cache")
    					return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ImmutableListMultimap.java

      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int keyCount = stream.readInt();
        if (keyCount < 0) {
          throw new InvalidObjectException("Invalid key count " + keyCount);
        }
        ImmutableMap.Builder<Object, ImmutableList<Object>> builder = ImmutableMap.builder();
        int tmpSize = 0;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "id":
    			z.ID, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ID")
    				return
    			}
    		case "cl":
    			z.CmdLine, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "CmdLine")
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/ByteSourceTest.java

        // Append 10 more bytes to the source.
        source.append(newPreFilledByteArray(5, 10));
    
        // 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());
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. docs/works_with_okhttp.md

     * [Communicator](https://github.com/Taig/Communicator): An OkHttp wrapper for Scala built with Android in mind.
     * [Cronet Transport for OkHttp](https://github.com/google/cronet-transport-for-okhttp): A HTTP3 ready transport layer for OkHttp on Android, based on Chromium network stack.
     * [CWAC-NetSecurity](https://github.com/commonsguy/cwac-netsecurity): Simplifying Secure Internet Access.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Jun 08 18:15:23 UTC 2022
    - 3.8K bytes
    - Viewed (0)
  7. buildscripts/verify-healing-empty-erasure-set.sh

    	"${MINIO[@]}" --address ":$((start_port + 3))" $args >"${WORK_DIR}/dist-minio-server3.log" 2>&1 &
    	pid3=$!
    	disown $pid3
    
    	export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))"
    
    	timeout 15m /tmp/mc ready myminio || fail
    
    	# Wait for all drives to be online and formatted
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_2x.md

    ## Version 2.5.0
    
    _2015-08-25_
    
     *  **Timeouts now default to 10 seconds.** Previously we defaulted to never
        timing out, and that was a lousy policy. If establishing a connection,
        reading the next byte from a connection, or writing the next byte to a
        connection takes more than 10 seconds to complete, you’ll need to adjust
        the timeouts manually.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  9. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        PULL_REQUEST_FEEDBACK("Pull Request Feedback", "Run various functional tests", "PullRequestFeedback"),
        READY_FOR_NIGHTLY("Ready for Nightly", "Rerun tests in different environments / 3rd party components", "ReadyforNightly"),
        READY_FOR_RELEASE("Ready for Release", "Once a day: Rerun tests in more environments", "ReadyforRelease"),
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 16 06:14:14 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeAll(headerBlock)
    
        // Check writer sends the same bytes.
        assertThat(sendHeaderFrames(false, sentHeaders)).isEqualTo(frame)
    
        // Reading the above frames should result in a concatenated headerBlock.
        reader.nextFrame(
          requireSettings = false,
          object : BaseTestHandler() {
            override fun headers(
              inFinished: Boolean,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top