- Sort Score
- Result 10 results
- Languages All
Results 641 - 650 of 871 for bool (0.02 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
var uriPort: Int = 1 fun newConnection( pool: RealConnectionPool, route: Route, idleAtNanos: Long = Long.MAX_VALUE, taskRunner: TaskRunner = this.taskRunner, ): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 7.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
MockResponse .Builder() .body("This connection won't pool properly") .onResponseEnd(ShutdownConnection) .build(), ) } @Test fun serverShutdownInput() { testServerClosesOutput( MockResponse .Builder() .body("This connection won't pool properly") .onResponseEnd( CloseSocket(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
int tasksPerThread = 10; int nTasks = nThreads * tasksPerThread; ExecutorService pool = newFixedThreadPool(nThreads); ImmutableList<String> keys = ImmutableList.of("a", "b", "c"); try { List<Future<int[]>> futures = newArrayListWithExpectedSize(nTasks); for (int i = 0; i < nTasks; i++) { futures.add(pool.submit(new MutateTask(multiset, keys))); } int[] deltas = new int[3];
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 6K bytes - Viewed (0) -
docs/features/connections.md
1. It uses the URL and configured OkHttpClient to create an **address**. This address specifies how we'll connect to the webserver. 2. It attempts to retrieve a connection with that address from the **connection pool**. 3. If it doesn't find a connection in the pool, it selects a **route** to attempt. This usually means making a DNS request to get the server's IP addresses. It then selects a TLS version and proxy server if necessary.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Feb 21 03:33:59 UTC 2022 - 5.4K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileFilterTest.java
// Arrange: filter delegates to isDirectory which may throw SmbException SmbFileFilter filter = f -> f.isDirectory(); SmbException boom = new SmbException("io error"); when(smbFile.isDirectory()).thenThrow(boom); // Act + Assert SmbException thrown = assertThrows(SmbException.class, () -> filter.accept(smbFile)); assertEquals("io error", thrown.getMessage());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.4K bytes - Viewed (0) -
docs/ko/docs/tutorial/header-param-models.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 09 12:45:39 UTC 2024 - 2K bytes - Viewed (0) -
src/test/java/jcifs/SmbTransportPoolTest.java
verify(transportPool).removeTransport(transport2); } } @Nested @DisplayName("Pool Lifecycle") class PoolLifecycleTests { @Test @DisplayName("Should close pool successfully with no active transports") void testClosePoolNoActiveTransports() throws CIFSException { // Given
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 22.6K bytes - Viewed (0) -
apache-maven/src/main/appended-resources/META-INF/LICENSE.vm
#* *##set ( $project.url = 'https://github.com/google/guice/' ) #* *##end #* *### #* *### Classworlds is in boot directory, not in lib #* *##if ( $project.artifact.artifactId == "plexus-classworlds" ) #* *##set ( $directory = 'boot' ) #* *##end #* *### #* *### copy license file to lib/$artifactId.license
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Jun 07 06:22:47 UTC 2025 - 4.2K bytes - Viewed (0) -
src/cmd/addr2line/addr2line_test.go
os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit. os.Exit(m.Run()) } func loadSyms(t *testing.T, dbgExePath string) map[string]string { cmd := testenv.Command(t, testenv.GoToolPath(t), "tool", "nm", dbgExePath) out, err := cmd.CombinedOutput() if err != nil { t.Fatalf("%v: %v\n%s", cmd, err, string(out)) } syms := make(map[string]string) scanner := bufio.NewScanner(bytes.NewReader(out))
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Sep 06 13:23:48 UTC 2024 - 3.2K bytes - Viewed (0) -
apache-maven/src/assembly/component.xml
<outputDirectory>lib</outputDirectory> <includes> <include>**</include> </includes> </fileSet> <fileSet> <directory>target/licenses/boot</directory> <outputDirectory>boot</outputDirectory> <includes> <include>**</include> </includes> </fileSet> <fileSet> <directory>src/assembly/maven/bin</directory>
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Jun 07 06:22:47 UTC 2025 - 3.6K bytes - Viewed (0)