- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 1,339 for contextos (0.06 sec)
-
internal/ioutil/ioutil.go
// If the deadline/context passes before the function finishes executing, // the zero value and the context error is returned. func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) { ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() c := make(chan ioret[V], 1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 10.9K bytes - Viewed (0) -
tests/test_dependency_contextvars.py
def test_dependency_contextvars(): """ Check that custom middlewares don't affect the contextvar context for dependencies. The code before yield and the code after yield should be run in the same contextvar context, so that request_state_context_var.reset(contextvar_token). If they are run in a different context, that raises an error. """ response = client.get("/user") assert response.json() == "deadpond"
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Feb 17 12:40:12 UTC 2022 - 1.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SetsFilterSortedSetTest.java
public final class SetsFilterSortedSetTest extends AbstractFilteredSortedSetTest<SortedSet<Integer>> { @Override SortedSet<Integer> createUnfiltered(Iterable<Integer> contents) { final TreeSet<Integer> result = Sets.newTreeSet(contents); // we have to make the result not Navigable return new ForwardingSortedSet<Integer>() { @Override protected SortedSet<Integer> delegate() { return result;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Mar 16 21:55:55 UTC 2022 - 1.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
Start(ctx context.Context) // IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error Stop() } type Server struct { ctx context.Context kubeClient kube.Client handlers K8sHandlers
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/lock-rest-server.go
success, err := l.ll.Lock(context.Background(), *args) if err == nil && !success { return l.makeResp(resp, errLockConflict) } return l.makeResp(resp, err) } // UnlockHandler - releases the acquired lock. func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCUnlock.NewResponse() _, err := l.ll.Unlock(context.Background(), *args)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.8K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib.h
template <typename DataType> std::unique_ptr<ParallelTensor> ScalarsFromSequence( absl::Span<const DataType> values, TFE_Context* context, TF_Status* status) const; // A parallel tensor with scalar integers numbering component devices. std::unique_ptr<ParallelTensor> DeviceIDs(TFE_Context* context, TF_Status* status) const; // The number of devices operations run on.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
package lsync_test import ( "context" "fmt" "runtime" "sync" "sync/atomic" "testing" "time" . "github.com/minio/minio/internal/lsync" ) func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { ctx := context.Background() lrwm := NewLRWMutex() if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 7.9K bytes - Viewed (0) -
docs/pt/docs/tutorial/request-files.md
Por exemplo, dentro de uma função de *operação de rota* `assíncrona`, você pode obter o conteúdo com: ```Python contents = await myfile.read() ``` Se você estiver dentro de uma função de *operação de rota* normal `def`, você pode acessar o `UploadFile.file` diretamente, por exemplo: ```Python contents = myfile.file.read() ``` /// note | Detalhes Técnicos do `async`
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 30 19:52:32 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/peer-s3-server.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 8.1K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
bucketMovingAvgTicker *time.Ticker // Ticker for calculating moving averages ctx context.Context // Context for generate NodeCount uint64 } // NewMonitor returns a monitor with defaults. func NewMonitor(ctx context.Context, numNodes uint64) *Monitor { m := &Monitor{ bucketsMeasurement: make(map[BucketOptions]*bucketMeasurement),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0)