Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,002 for Blaser (0.27 sec)

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

     *
     * <pre>{@code
     * Closer closer = Closer.create();
     * try {
     *   InputStream in = closer.register(openInputStream());
     *   OutputStream out = closer.register(openOutputStream());
     *   // do stuff
     * } catch (Throwable e) {
     *   // ensure that any checked exception types other than IOException that could be thrown are
     *   // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Mar 06 15:15:46 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    func (b *streamingBitrotReader) Close() error {
    	if b.rc == nil {
    		return nil
    	}
    	if closer, ok := b.rc.(io.Closer); ok {
    		// drain the body for connection reuse at network layer.
    		xhttp.DrainBody(struct {
    			io.Reader
    			io.Closer
    		}{
    			Reader: b.rc,
    			Closer: closeWrapper(func() error { return nil }),
    		})
    		return closer.Close()
    	}
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * <pre>{@code
     * FluentFuture<UserName> userName =
     *     ClosingFuture.submit(
     *             closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
     *         .transform((closer, result) -> result.get("userName"), directExecutor())
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  4. cmd/server-main_test.go

    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		t.Fatal("Unexpected object layer initialization error", err)
    	}
    
    	_, ok := obj.(*erasureServerPools)
    	if !ok {
    		t.Fatal("Unexpected object layer detected", reflect.TypeOf(obj))
    	}
    
    	// Tests for Erasure object layer initialization.
    
    	// Create temporary backend for the test server.
    	nDisks = 16
    	disks, err = getRandomDisks(nDisks)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Dec 07 09:33:56 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. cmd/xl-storage_unix_test.go

    		expectedUmask int
    	}{
    		{"is-this-valid", getUmask()},
    	}
    	testCase := testCases[0]
    
    	// Initialize a new xlStorage layer.
    	disk, err := newLocalXLStorage(tmpPath)
    	if err != nil {
    		t.Fatalf("Initializing xlStorage failed with %s.", err)
    	}
    
    	// Attempt to create a volume to verify the permissions later.
    	// MakeVol creates 0777.
    	if err = disk.MakeVol(context.Background(), testCase.volName); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  6. cmd/bitrot_test.go

    		t.Fatal(err)
    	}
    	_, err = writer.Write([]byte("aaaaaaaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = writer.Write([]byte("aaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	if bw, ok := writer.(io.Closer); ok {
    		bw.Close()
    	}
    
    	reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10)
    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  7. cmd/object-api-common.go

    	deletedBucketsPrefix = ".deleted"
    
    	// ETag (hex encoded md5sum) of empty string.
    	emptyETag = "d41d8cd98f00b204e9800998ecf8427e"
    )
    
    // Global object layer mutex, used for safely updating object layer.
    var globalObjLayerMutex sync.RWMutex
    
    // Global object layer, only accessed by globalObjectAPI.
    var globalObjectAPI ObjectLayer
    
    type storageOpts struct {
    	cleanUp     bool
    	healthCheck bool
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  8. docs/es/docs/python-types.md

        * Los valores de este `dict` son de tipo `float` (Digamos que son el precio de cada ítem).
    
    ### Clases como tipos
    
    También puedes declarar una clase como el tipo de una variable.
    
    Digamos que tienes una clase `Person`con un nombre:
    
    ```Python hl_lines="1-3"
    {!../../../docs_src/python_types/tutorial009.py!}
    ```
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Fri Mar 22 01:42:11 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  9. docs/es/docs/tutorial/cookie-params.md

        {!> ../../../docs_src/cookie_params/tutorial001.py!}
        ```
    
    !!! note "Detalles Técnicos"
        `Cookie` es una clase "hermana" de `Path` y `Query`. También hereda de la misma clase común `Param`.
    
        Pero recuerda que cuando importas `Query`, `Path`, `Cookie`  y otros de `fastapi`, en realidad son funciones que devuelven clases especiales.
    
    !!! info
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Fri Apr 19 19:30:26 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  10. internal/http/request-recorder.go

    	io.Reader
    	// Response body should be logged
    	LogBody bool
    
    	// internal recording buffer
    	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) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 12 21:37:19 GMT 2023
    - 1.8K bytes
    - Viewed (0)
Back to top