Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 1,189 for Reader (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

            }
          }
    
          // There's another part. Parse its headers and return it.
          val headers = HeadersReader(source).readHeaders()
          val partSource = PartSource()
          currentPart = partSource
          return Part(headers, partSource.buffer())
        }
    
        /** A single part in the stream. It is an error to read this after calling [nextPart]. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. compat/maven-compat/pom.xml

              </models>
            </configuration>
            <executions>
              <execution>
                <id>modello</id>
                <goals>
                  <goal>java</goal>
                  <goal>xpp3-reader</goal>
                  <goal>xpp3-writer</goal>
                </goals>
              </execution>
            </executions>
          </plugin>
        </plugins>
      </build>
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Sun Jun 29 22:37:39 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  3. api/go1.23.txt

    pkg net/http, type Cookie struct, Quoted bool #46443
    pkg net/http, type Request struct, Pattern string #66405
    pkg net/http/httptest, func NewRequestWithContext(context.Context, string, string, io.Reader) *http.Request #59473
    pkg os, func CopyFS(string, fs.FS) error #62484
    pkg path/filepath, func Localize(string) (string, error) #57151
    pkg reflect, func SliceAt(Type, unsafe.Pointer, int) Value #61308
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 25 17:08:08 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. cmd/erasure_test.go

    	{dataBlocks: 8, parityBlocks: 4, missingData: 2, missingParity: 2, reconstructParity: false, shouldFail: false},
    }
    
    func TestErasureEncodeDecode(t *testing.T) {
    	data := make([]byte, 256)
    	if _, err := io.ReadFull(rand.Reader, data); err != nil {
    		t.Fatalf("Failed to read random data: %v", err)
    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  5. src/archive/zip/writer.go

    	// flag bit is set. However, there are several problems:
    	//
    	//	* Many ZIP readers still do not support UTF-8.
    	//	* If the UTF-8 flag is cleared, several readers simply interpret the
    	//	name and comment fields as whatever the local system encoding is.
    	//
    	// In order to avoid breaking readers without UTF-8 support,
    	// we avoid setting the UTF-8 flag if the strings are CP-437 compatible.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jan 28 04:20:09 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    	PutObject(ctx context.Context, bucket, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error)
    }
    
    // load the cache content with name from minioMetaBackgroundOpsBucket.
    // Only backend errors are returned as errors.
    // The loader is optimistic and has no locking, but tries 5 times before giving up.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    			return err
    		}
    
    		cHeader := http.Header{}
    		cHeader.Add(xhttp.MinIOSourceReplicationRequest, "true")
    		if !isSSEC {
    			cs, _ := getCRCMeta(objInfo, partInfo.Number, nil)
    			for k, v := range cs {
    				cHeader.Add(k, v)
    			}
    		}
    		popts := minio.PutObjectPartOptions{
    			SSE:          opts.ServerSideEncryption,
    			CustomHeader: cHeader,
    		}
    
    		var size int64
    		if isSSEC {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  8. cmd/bucket-metadata.go

    	if err != nil {
    		return
    	}
    
    	outbuf := bytes.NewBuffer(nil)
    	objectKey := crypto.GenerateKey(key.Plaintext, rand.Reader)
    	sealedKey := objectKey.Seal(key.Plaintext, crypto.GenerateIV(rand.Reader), crypto.S3.String(), bucket, "")
    	crypto.S3.CreateMetadata(metadata, key.KeyID, key.Ciphertext, sealedKey)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

          Header("content-disposition", ""),
          Header("content-encoding", ""),
          Header("content-language", ""),
          Header("content-length", ""),
          Header("content-location", ""),
          Header("content-range", ""),
          Header("content-type", ""),
          Header("cookie", ""),
          Header("date", ""),
          Header("etag", ""),
          Header("expect", ""),
          Header("expires", ""),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

    import okhttp3.internal.ws.WebSocketProtocol.toggleMask
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame reader.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketReader(
      private val isClient: Boolean,
      val source: BufferedSource,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
Back to top