Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 221 for Reads (0.04 sec)

  1. internal/etag/reader.go

    // ETag returns the ETag of the underlying Tagger.
    func (r wrapReader) ETag() ETag {
    	if r.Tagger == nil {
    		return nil
    	}
    	return r.Tagger.ETag()
    }
    
    // Wrap returns an io.Reader that reads from the wrapped
    // io.Reader and implements the Tagger interaface.
    //
    // If content implements Tagger then the returned Reader
    // returns ETag of the content. Otherwise, it returns
    // nil as ETag.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

            fileOperator!!.read(FILE_HEADER_SIZE + sourcePos, sink, bytesToRead)
            sourcePos += bytesToRead
            return bytesToRead
          }
    
          // Read from upstream. This always reads a full buffer: that might be more than what the
          // current call to Source.read() has requested.
          try {
            val upstreamBytesRead = upstream!!.read(upstreamBuffer, bufferMaxSize)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbNamedPipe.java

     *
     * <ul>
     * <li><code>CallNamedPipe</code> A message-type pipe call that opens,
     * writes to, reads from, and closes the pipe in a single operation.
     * <li><code>TransactNamedPipe</code> A message-type pipe call that
     * writes to and reads from an existing pipe descriptor in one operation.
     * <li><code>CreateFile</code>, <code>ReadFile</code>,
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6K bytes
    - Viewed (0)
  4. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

            readStory(story00)
            result.add(path.name)
          } catch (ignored: IOException) {
            // Skip this path.
          }
        }
        return result.toTypedArray<String>()
      }
    
      /**
       * Reads stories named "story_xx.json" from the folder provided.
       */
      fun readStories(testFolderName: String): List<Story> {
        val result = mutableListOf<Story>()
        var i = 0
        while (true) { // break after last test.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt

     * typically false on Windows.
     *
     * If this returns false we won't permit simultaneous reads and writes. When writes commit we need
     * to delete the previous snapshots, and that won't succeed if the file is open. (We do permit
     * multiple simultaneous reads.)
     *
     * @param file a file in the directory to check. This file shouldn't already exist!
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 11K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer.go

    }
    
    // CloseWithError closes the writer; reads will return
    // no bytes and the error err, or EOF if err is nil.
    //
    // CloseWithError never overwrites the previous error if it exists
    // and always returns nil.
    func (r *RingBuffer) CloseWithError(err error) {
    	if err == nil {
    		err = io.EOF
    	}
    	r.setErr(err, false)
    }
    
    // CloseWriter closes the writer.
    // Reads will return any remaining bytes and io.EOF.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

     *
     * <ul>
     * <li> <code>CallNamedPipe</code> A message-type pipe call that opens,
     *      writes to, reads from, and closes the pipe in a single operation.
     * <li> <code>TransactNamedPipe</code> A message-type pipe call that
     *      writes to and reads from an existing pipe descriptor in one operation.
     * <li> <code>CreateFile</code>, <code>ReadFile</code>,
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.3K bytes
    - Viewed (0)
  8. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

          assertSetEquals(
            "seqno=$testCase.seqno",
            testCase.headersList,
            hpackReader.getAndResetHeaderList(),
          )
        }
      }
    
      companion object {
        /**
         * Reads all stories in the folders provided, asserts if no story found.
         */
        @JvmStatic
        protected fun createStories(interopTests: Array<String>): List<Any> {
          if (interopTests.isEmpty()) return listOf<Any>(Story.MISSING)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      host == other.host &&
        port == other.port &&
        scheme == other.scheme
    
    internal fun EventListener.asFactory() = EventListener.Factory { this }
    
    /**
     * Reads until this is exhausted or the deadline has been reached. This is careful to not extend the
     * deadline if one exists already.
     */
    @Throws(IOException::class)
    internal fun Source.skipAll(
      duration: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. internal/http/request-recorder.go

    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    		r.buf.Write(p[:n])
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top