- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 74 for Sequence (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
private var mostRecentRebuildFailed: Boolean = false /** * To differentiate between old and current snapshots, each entry is given a sequence number each * time an edit is committed. A snapshot is stale if its sequence number is not equal to its * entry's sequence number. */ private var nextSequenceNumber: Long = 0 private val cleanupQueue = taskRunner.newQueue() private val cleanupTask =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt
else -> error("Unexpected ${this::class}") } /** * Note: The resulting sequence does not contain non-qualified types! * * For type `A.B.C.D` it will return sequence of [`A.B.C.D`, `A.B.C`, `A.B`] (**without** `A`). */ private val KtUserType.qualifiedTypesWithSelf: Sequence<KtUserType> get() { require(qualifier != null) {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 25 18:51:33 GMT 2024 - 69.5K bytes - Viewed (0) -
src/README.vendor
set to 'on' or 'auto', and if you use a go.work file, set GOWORK=off. Requirements may be added, updated, and removed with 'go get'. The vendor directory may be updated with 'go mod vendor'. A typical sequence might be: cd src # or src/cmd go get golang.org/x/net@master go mod tidy go mod vendor Use caution when passing '-u' to 'go get'. The '-u' flag updates
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 02 02:20:05 GMT 2024 - 2.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
import mockwebserver3.StreamHandler import okio.utf8Size private typealias Action = (Stream) -> Unit /** * A scriptable request/response conversation. Create the script by calling methods like * [receiveRequest] in the sequence they are run. */ class MockStreamHandler : StreamHandler { private val actions = LinkedBlockingQueue<Action>() private val results = LinkedBlockingQueue<FutureTask<Void>>() fun receiveRequest(expected: String) =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10SymbolProvider.kt
return descriptor.toKtClassifierSymbol(analysisContext) as? KtTypeAliasSymbol } override fun getTopLevelCallableSymbols(packageFqName: FqName, name: Name): Sequence<KtCallableSymbol> { val packageViewDescriptor = analysisContext.resolveSession.moduleDescriptor.getPackage(packageFqName)
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Aug 17 13:01:02 GMT 2023 - 7K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt
), ) .assertLogMatch( Regex( """callFailed: \S+(?:SSLProtocolException|SSLHandshakeException|TlsFatalAlert): (?:Unexpected handshake message: client_hello|Handshake message sequence violation, 1|Read error|Handshake failed|unexpected_message\(10\)).*""",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
if (peek == null) { skipCommasAndWhitespace() peek = readToken() if (peek == null) return } val schemeName = peek // Read a token68, a sequence of parameters, or nothing. val commaPrefixed = skipCommasAndWhitespace() peek = readToken() if (peek == null) { if (!exhausted()) return // Expected a token; got something else.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
return eventClass.cast(event) } } } catch (e: NoSuchElementException) { throw AssertionError("full event sequence: $fullEventSequence", e) } } /** * Remove and return the next event from the recorded sequence. * * @param eventClass a class to assert that the returned event is an instance of, or null to * take any event class.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
* * While [onReset] may occur at any time, the following callbacks are expected in order, * correlated by stream ID. * * * [onRequest] * * [onHeaders] (unless canceled) * * [onData] (optional sequence of data frames) * * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple * connections should expect repetition of stream IDs. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/KDocReferenceResolver.kt
} } private fun generateNameInterpretations(fqName: FqName): Sequence<FqNameInterpretation> = sequence { val parts = fqName.pathSegments() if (parts.isEmpty()) { yield(FqNameInterpretation.create(packageParts = emptyList(), classParts = emptyList(), callable = null)) return@sequence } for (lastPackagePartIndexExclusive in 0..parts.size) { yield(
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Fri Apr 19 11:06:47 GMT 2024 - 22.6K bytes - Viewed (0)