- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for Stuart (0.26 sec)
-
fastapi/routing.py
lifespan=lifespan, ) if prefix: assert prefix.startswith("/"), "A path prefix must start with '/'" assert not prefix.endswith( "/" ), "A path prefix must not end with '/', as the routes will start with '/'" self.prefix = prefix self.tags: List[Union[str, Enum]] = tags or [] self.dependencies = list(dependencies or [])
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 170.1K bytes - Viewed (0) -
cmd/bucket-replication.go
} } for i := 0; i < resyncParallelRoutines; i++ { xioutil.SafeClose(workers[i]) } wg.Wait() resyncStatus = ResyncCompleted } // start replication resync for the remote target ARN specified func (s *replicationResyncer) start(ctx context.Context, objAPI ObjectLayer, opts resyncOpts) error { if opts.bucket == "" { return fmt.Errorf("bucket name is empty") } if opts.arn == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/CacheTest.kt
expectedResponseCode = 200 server.enqueue( MockResponse.Builder() .setHeader("Cache-Control", "no-store") .body("FGHIJ") .build(), ) } server.start() val request = Request.Builder() .url(server.url("/")) .build() val response = client.newCall(request).execute() assertThat(response.code).isEqualTo(expectedResponseCode)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
// TODO(fry): could also cancel loading if we had a handle on its future } public ListenableFuture<V> loadFuture(K key, CacheLoader<? super K, V> loader) { try { stopwatch.start(); V previousValue = oldValue.get(); if (previousValue == null) { V newValue = loader.load(key); return set(newValue) ? futureValue : Futures.immediateFuture(newValue); }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
doc/go1.17_spec.html
</p> <ol> <li> <i>Line comments</i> start with the character sequence <code>//</code> and stop at the end of the line. </li> <li> <i>General comments</i> start with the character sequence <code>/*</code> and stop with the first subsequent character sequence <code>*/</code>. </li> </ol> <p> A comment cannot start inside a <a href="#Rune_literals">rune</a> or
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 211.6K bytes - Viewed (0) -
cmd/site-replication.go
res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{ ErrDetail: err.Error(), Bucket: bucket, }) continue } if err := globalReplicationPool.resyncer.start(ctx, objAPI, resyncOpts{ bucket: bucket, arn: tgtArn, resyncID: rs.ResyncID, }); err != nil { res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{ ErrDetail: err.Error(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
fastapi/applications.py
app = FastAPI() @app.middleware("http") async def add_process_time_header(request: Request, call_next): start_time = time.time() response = await call_next(request) process_time = time.time() - start_time response.headers["X-Process-Time"] = str(process_time) return response ``` """
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 172.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
try { sleep(delay) } catch (e: InterruptedException) { throw AssertionError() } call.cancel() } } thread.start() return thread } private fun socketFactoryWithCipherSuite( sslSocketFactory: SSLSocketFactory, cipherSuite: CipherSuite, ): SSLSocketFactory {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
cmd/server_test.go
s.testServer.cancel = cancel s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths) if s.secure { s.testServer.Server.StartTLS() } else { s.testServer.Server.Start() } s.client = s.testServer.Server.Client() s.endPoint = s.testServer.Server.URL } func (s *TestSuiteCommon) TearDownSuite(c *check) { s.testServer.Stop() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
tensorflow/c/c_api.cc
#if defined(IS_MOBILE_PLATFORM) || defined(IS_SLIM_BUILD) status->status = tensorflow::errors::Unimplemented( "Server functionality is not supported on mobile"); #else status->status = server->server->Start(); #endif // defined(IS_MOBILE_PLATFORM) || defined(IS_SLIM_BUILD) } void TF_ServerStop(TF_Server* server, TF_Status* status) { #if defined(IS_MOBILE_PLATFORM) || defined(IS_SLIM_BUILD)
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 102.3K bytes - Viewed (0)