Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 599 for readAs (0.09 sec)

  1. README.md

    <summary>About the command <code>fastapi dev main.py</code>...</summary>
    
    The command `fastapi dev` reads your `main.py` file, detects the **FastAPI** app in it, and starts a server using <a href="https://www.uvicorn.org" class="external-link" target="_blank">Uvicorn</a>.
    
    By default, `fastapi dev` will start with auto-reload enabled for local development.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 15:19:49 UTC 2025
    - 24.3K bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		closeBitrotWriters(writers)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. src/bufio/scan_test.go

    			t.Errorf("#%d: %v", n, err)
    		}
    	}
    }
    
    // slowReader is a reader that returns only a few bytes at a time, to test the incremental
    // reads in Scanner.Scan.
    type slowReader struct {
    	max int
    	buf io.Reader
    }
    
    func (sr *slowReader) Read(p []byte) (n int, err error) {
    	if len(p) > sr.max {
    		p = p[0:sr.max]
    	}
    	return sr.buf.Read(p)
    }
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/lex/tokenizer.go

    // for our purposes and made a TokenReader. It forms the lowest level,
    // turning text from readers into tokens.
    type Tokenizer struct {
    	tok  ScanToken
    	s    *scanner.Scanner
    	base *src.PosBase
    	line int
    	file *os.File // If non-nil, file descriptor to close.
    }
    
    func NewTokenizer(name string, r io.Reader, file *os.File) *Tokenizer {
    	var s scanner.Scanner
    	s.Init(r)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Aug 04 20:35:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    			return s2w.Close()
    		}
    		return nil
    	}
    }
    
    var s2DecPool = bpool.Pool[*s2.Reader]{New: func() *s2.Reader {
    	// Default alloc block for network transfer.
    	return s2.NewReader(nil, s2.ReaderAllocBlock(16<<10))
    }}
    
    // metacacheReader allows reading a cache stream.
    type metacacheReader struct {
    	mr      *msgp.Reader
    	current metaCacheEntry
    	err     error // stateful error
    	closer  func()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        internal val reader: Http2Reader,
      ) : Http2Reader.Handler,
        () -> Unit {
        override fun invoke() {
          var connectionErrorCode = ErrorCode.INTERNAL_ERROR
          var streamErrorCode = ErrorCode.INTERNAL_ERROR
          var errorException: IOException? = null
          try {
            reader.readConnectionPreface(this)
            while (reader.nextFrame(false, this)) {
            }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    		// - xl.meta for inlined objects has already read the data
    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

            "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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. cmd/bitrot-streaming.go

    	}()
    	return bw
    }
    
    // ReadAt() implementation which verifies the bitrot hash available as part of the stream.
    type streamingBitrotReader struct {
    	disk       StorageAPI
    	data       []byte
    	rc         io.Reader
    	volume     string
    	filePath   string
    	tillOffset int64
    	currOffset int64
    	h          hash.Hash
    	shardSize  int64
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  10. doc/next/6-stdlib/99-minor/README

    Michael Anthony Knyszek <******@****.***> 1753293006 +0000
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Jul 23 18:41:17 UTC 2025
    - 69 bytes
    - Viewed (0)
Back to top