Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 712 for readFn (0.8 sec)

  1. docs/recipes.md

    ### Asynchronous Get ([.kt][AsynchronousGetKotlin], [.java][AsynchronousGetJava])
    
    Download a file on a worker thread, and get called back when the response is readable. The callback is made after the response headers are ready. Reading the response body may still block. OkHttp doesn't currently offer asynchronous APIs to receive a response body in parts.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
          private val client = OkHttpClient()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  2. cmd/object-api-datatypes.go

    	UserTags string
    
    	// List of individual parts, maximum size of upto 10,000
    	Parts []ObjectPartInfo `json:"-"`
    
    	// Implements writer and reader used by CopyObject API
    	Writer       io.WriteCloser `json:"-" msg:"-"`
    	Reader       *hash.Reader   `json:"-" msg:"-"`
    	PutObjReader *PutObjReader  `json:"-" msg:"-"`
    
    	metadataOnly bool
    	versionOnly  bool // adds a new version, only used by CopyObject
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  3. docs/debugging/inspect/main.go

    			} else {
    				break
    			}
    			n++
    		}
    
    		// Prompt for decryption key if no --key or --private-key are provided
    		if len(privateKeys) == 0 && !*stdin {
    			reader := bufio.NewReader(os.Stdin)
    			fmt.Print("Enter Decryption Key: ")
    
    			text, _ := reader.ReadString('\n')
    			// convert CRLF to LF
    			*keyHex = strings.ReplaceAll(text, "\n", "")
    			*keyHex = strings.TrimSpace(*keyHex)
    		}
    	}
    
    	var inputs []string
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 17 17:09:42 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/netbios/Lmhosts.java

    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileNotFoundException;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import java.util.Hashtable;
    
    import jcifs.smb1.Config;
    import jcifs.smb1.smb1.SmbFileInputStream;
    import jcifs.smb1.util.LogStream;
    
    /**
     * Lmhosts file handling for NetBIOS name resolution.
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6K bytes
    - Viewed (0)
  5. cmd/site-replication-metrics_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *RStat) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  6. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

          // Replace the body with a stripped one so the callbacks can't see real data.
          val response = response.stripBody()
    
          val reader = ServerSentEventReader(body.source(), this)
          try {
            if (!canceled) {
              listener.onOpen(this, response)
              while (!canceled && reader.processNextEvent()) {
              }
            }
          } catch (e: Exception) {
            val exception =
              when {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/opensearch/config/bsentity/dbmeta/ElevateWordDbm.java

                false, false, false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
        protected final ColumnInfo _columnReading = cci("reading", "reading", null, null, String.class, "reading", null, false, false, false,
                "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. src/archive/zip/testdata/zip64-2.zip

    README This small file is in ZIP64 format....
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Sep 08 04:08:51 UTC 2014
    - 266 bytes
    - Viewed (0)
  10. api/go1.7.txt

    pkg bytes, func ContainsAny([]uint8, string) bool
    pkg bytes, func ContainsRune([]uint8, int32) bool
    pkg bytes, method (*Reader) Reset([]uint8)
    pkg compress/flate, const HuffmanOnly = -2
    pkg compress/flate, const HuffmanOnly ideal-int
    pkg context, func Background() Context
    pkg context, func TODO() Context
    pkg context, func WithCancel(Context) (Context, CancelFunc)
    pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
Back to top