Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 26 for Unwrap (0.04 seconds)

  1. cmd/api-response_test.go

    		t.Fatalf("reading response body failed: %v", err)
    	}
    	if string(body) != "hello" {
    		t.Fatalf("response body incorrect: %v", string(body))
    	}
    
    	// Check that Unwrap works
    	if trw.Unwrap() != rw {
    		t.Fatalf("Unwrap returned wrong result: %v", trw.Unwrap())
    	}
    }
    
    func TestHeadersAlreadyWritten(t *testing.T) {
    	rw := httptest.NewRecorder()
    	trw := &trackingResponseWriter{ResponseWriter: rw}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  2. tensorflow/c/c_api_experimental.cc

        return;
      }
      status->status = tensorflow::unwrap(ctx)->EnableCollectiveOps(server_def);
    }
    
    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status) {
      tensorflow::EagerContext* context =
          tensorflow::ContextFromInterface(tensorflow::unwrap(ctx));
      auto collective_executor_handle = context->GetCollectiveExecutorHandle();
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat Oct 04 05:55:32 GMT 2025
    - 29.4K bytes
    - Click Count (0)
  3. cmd/api-response.go

    	writeResponse(w, err.HTTPStatusCode, encodedErrorResponse, mimeJSON)
    }
    
    type unwrapper interface {
    	Unwrap() http.ResponseWriter
    }
    
    // headersAlreadyWritten returns true if the headers have already been written
    // to this response writer. It will unwrap the ResponseWriter if possible to try
    // and find a trackingResponseWriter.
    func headersAlreadyWritten(w http.ResponseWriter) bool {
    	for {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 35K bytes
    - Click Count (0)
  4. cmd/admin-handlers-config-kv.go

    }
    
    type badConfigErr struct {
    	Err error
    }
    
    // Error - return the error message
    func (bce badConfigErr) Error() string {
    	return bce.Err.Error()
    }
    
    // Unwrap the error to its underlying error.
    func (bce badConfigErr) Unwrap() error {
    	return bce.Err
    }
    
    type setConfigResult struct {
    	Cfg                     config.Config
    	SubSys                  string
    	Dynamic                 bool
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.8K bytes
    - Click Count (1)
  5. fastapi/dependencies/models.py

    else:  # pragma: no cover
        from asyncio import iscoroutinefunction
    
    
    def _unwrapped_call(call: Optional[Callable[..., Any]]) -> Any:
        if call is None:
            return call  # pragma: no cover
        unwrapped = inspect.unwrap(_impartial(call))
        return unwrapped
    
    
    def _impartial(func: Callable[..., Any]) -> Callable[..., Any]:
        while isinstance(func, partial):
            func = func.func
        return func
    
    
    @dataclass
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  6. internal/rest/client.go

    type NetworkError struct {
    	Err error
    }
    
    func (n *NetworkError) Error() string {
    	return n.Err.Error()
    }
    
    // Unwrap returns the error wrapped in NetworkError.
    func (n *NetworkError) Unwrap() error {
    	return n.Err
    }
    
    // Client - http based RPC client.
    type Client struct {
    	connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. fastapi/dependencies/utils.py

        else:
            signature = inspect.signature(call)
        return signature
    
    
    def get_typed_signature(call: Callable[..., Any]) -> inspect.Signature:
        signature = _get_signature(call)
        unwrapped = inspect.unwrap(call)
        globalns = getattr(unwrapped, "__globals__", {})
        typed_params = [
            inspect.Parameter(
                name=param.name,
                kind=param.kind,
                default=param.default,
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 37.6K bytes
    - Click Count (3)
  8. cmd/utils.go

    		return "", fmt.Errorf("id_token not found!")
    	}
    
    	// fmt.Printf("TOKEN: %s\n", rawIDToken)
    	return rawIDToken, nil
    }
    
    // unwrapAll will unwrap the returned error completely.
    func unwrapAll(err error) error {
    	for {
    		werr := errors.Unwrap(err)
    		if werr == nil {
    			return err
    		}
    		err = werr
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  9. cmd/site-replication.go

    		},
    		configureReplication,
    	)
    
    	if err := errors.Unwrap(makeBucketConcErr); err != nil {
    		return err
    	}
    	return errors.Unwrap(makeRemotesConcErr)
    }
    
    // DeleteBucketHook - called during a regular delete bucket call when cluster
    // replication is enabled. It is responsible for the deletion of the same bucket
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  10. association.go

    		}}})
    	} else {
    		tx.Clauses(clause.Where{Exprs: queryConds})
    	}
    
    	return tx
    }
    
    func expandValues(values ...any) (results []any) {
    	appendToResult := func(rv reflect.Value) {
    		// unwrap interface
    		if rv.IsValid() && rv.Kind() == reflect.Interface {
    			rv = rv.Elem()
    		}
    		if rv.IsValid() && rv.Kind() == reflect.Struct {
    			p := reflect.New(rv.Type())
    			p.Elem().Set(rv)
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:09:12 GMT 2025
    - 23.6K bytes
    - Click Count (0)
Back to Top