- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 462 for slop (0.03 sec)
-
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
import org.junit.jupiter.api.extension.RegisterExtension import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ValueSource @Flaky // STDOUT logging enabled for test @Timeout(30) @Tag("Slow") open class ConnectionListenerTest { @RegisterExtension val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private var server: MockWebServer? = null
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.6K bytes - Viewed (0) -
internal/config/scanner/help.go
return config.DefaultHelpPostfix(DefaultKVS, key) } // Help provides help for config values Help = config.HelpKVS{ config.HelpKV{ Key: Speed, Description: `customize scanner speed (default|slowest|slow|fast|fastest)` + defaultHelpPostfix(Speed), Optional: true, Type: "string", }, config.HelpKV{ Key: ExcessVersions,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:41:53 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/metacache.go
// we intentionally operate on a copy of m, so we can update without locks. t := time.NewTicker(metacacheMaxClientWait / 10) defer t.Stop() for { select { case <-ctx.Done(): // Request is done, stop updating. return case <-t.C: m.lastHandout = time.Now() if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil { if m2.status != scanStateStarted {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/JodExtractor.java
} } @PreDestroy public void destroy() { try { officeManager.stop(); } catch (final OfficeException e) { throw new CrawlerSystemException("Failed to stop officeManager.", e); } } public void addConversionRule(final String inExt, final String outExt) { extensionMap.put(inExt, outExt);
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 8.2K bytes - Viewed (0) -
internal/event/target/nsq.go
} // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil } func (target *NSQTarget) init() error { return target.initOnce.Do(target.initNSQ) } func (target *NSQTarget) initNSQ() error { args := target.args
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0) -
build-logic/buildquality/src/test/kotlin/gradlebuild/testcleanup/TestFilesCleanupServiceTest.kt
assertEquals(1, StringUtils.countMatches(result.output, "Found non-empty test files dir")) assertEquals(1, StringUtils.countMatches(result.output, "Failed to stop service 'testFilesCleanupBuildService'")) result.output.assertContains("successful-test-with-leftover/build/tmp/teŝt files/leftover")
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Jun 14 12:35:52 UTC 2023 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/exentity/ScheduledJob.java
job.launchNow(); }).orElse(() -> { throw new JobNotFoundException(this); }); } public void stop() { ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> { job.stopNow(); }).orElse(() -> { throw new JobNotFoundException(this); });
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.1K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt
*/ class JettyHttpClientTest { private val client = HttpClient() @BeforeEach fun setUp() { client.start() } @AfterEach fun tearDown() { client.stop() } @Test fun get(server: MockWebServer) { server.enqueue(MockResponse(body = "hello, Jetty HTTP Client")) val request = client.newRequest(server.url("/").toUri())
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
docs/vi/docs/python-types.md
//// tab | Python 3.8+ * `List` * `Tuple` * `Set` * `Dict` * `Union` * `Optional` * ...và các kiểu khác. //// ### Lớp như kiểu dữ liệu Bạn cũng có thể khai báo một lớp như là kiểu dữ liệu của một biến. Hãy nói rằng bạn muốn có một lớp `Person` với một tên: ```Python hl_lines="1-3" {!../../docs_src/python_types/tutorial010.py!} ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 21.6K bytes - Viewed (0) -
docs/features/connections.md
(like HTTP/2). URLs that share the same address may also share the same underlying TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections....
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Feb 21 03:33:59 UTC 2022 - 5.4K bytes - Viewed (0)