- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for Tiller (0.2 sec)
-
native-image-tests/src/main/kotlin/okhttp3/RunTests.kt
val sampleTestClass = SampleTest::class.java val lines = inputFile?.readLines() ?: sampleTestClass.getResource("/testlist.txt").readText().lines() val flatClassnameList = lines .filter { it.isNotBlank() } return flatClassnameList .mapNotNull { try { selectClass(Class.forName(it, false, sampleTestClass.classLoader)) } catch (cnfe: ClassNotFoundException) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
* have been received. If the returned list contains multiple blocks of headers the blocks will be * delimited by 'null'. * * @param callerIsIdle true if the caller isn't sending any more bytes until the peer responds. * This is true after a `Expect-Continue` request, false for duplex requests, and false for * all other requests. */ @Throws(IOException::class)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
Arrays.fill(array, c) return String(array) } /** * Okio buffers are internally implemented as a linked list of arrays. Usually this implementation * detail is invisible to the caller, but subtle use of certain APIs may depend on these internal * structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/osgi/OsgiTest.kt
// available in the repository. val runRequireString = REQUIRED_BUNDLES.joinToString(separator = ",") { "osgi.identity;filter:='(osgi.identity=$it)'" } val bndEditModel = BndEditModel(workspace).apply { // Temporary project to satisfy bnd API. project = Project(workspace, workspaceDir.toFile()) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
val b0 = this[index].code val b1 = this[index + 1].code return (b0 shl 7) + b1 } /** * An extremely generic binary search that doesn't know what data it's searching over. The caller * provides indexes and a comparison function, and this calls that function iteratively. * * @return the index of the match. If no match is found this is `(-1 - insertionPoint)`, where the
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Apr 02 11:39:58 GMT 2024 - 9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
import okio.ByteString.Companion.toByteString /** * Logs SSL keys to a log file, allowing Wireshark to decode traffic and be examined with http2 * filter. The approach is to hook into JSSE log events for the messages between client and server * during handshake, and then take the agreed masterSecret from private fields of the session. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
open fun responseFailed( call: Call, ioe: IOException, ) { } /** * Invoked immediately after a call has completely ended. This includes delayed consumption * of response body by the caller. * * This method is always invoked after [callStart]. */ open fun callEnd(call: Call) { } /** * Invoked when a call fails permanently. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* hosting filesystem becomes unreachable, the iterator will omit elements rather than throwing * exceptions. * * **The caller must [close][Snapshot.close]** each snapshot returned by [Iterator.next]. Failing * to do so leaks open files! */ @Synchronized @Throws(IOException::class) fun snapshots(): MutableIterator<Snapshot> {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
val response1 = client.newCall(request).execute() assertThat(response1.body.string()).isEqualTo("ABC") val cacheEntry = fileSystem.allPaths.stream() .filter { e: Path -> e.name.endsWith(".0") } .findFirst() .orElseThrow { NoSuchElementException() } corruptCertificate(cacheEntry) val response2 = client.newCall(request).execute() // Not Cached!
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) cancelLatch.await() val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name } listener.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0)