- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 131 for lang (0.22 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */ private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) } /**
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-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
} else { val source = responseBody.source() source.request(Long.MAX_VALUE) // Buffer the entire body. val totalMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs) var buffer = source.buffer var gzippedLength: Long? = null if ("gzip".equals(headers["Content-Encoding"], ignoreCase = true)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
docs/changelogs/changelog_4x.md
OkHttp 4.x Change Log ===================== ## Version 4.12.0 _2023-10-16_ * Fix: Don't hang taking headers for HTTP 103 responses. * Fix: Recover gracefully when a cache entry's certificate is corrupted. * Fix: Fail permanently when there's a failure loading the bundled public suffix database. This is the dataset that powers `HttpUrl.topPrivateDomain()`.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
import java.util.ArrayDeque import java.util.Deque import okio.Buffer import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Test class ServerSentEventIteratorTest { /** Either [Event] or [Long] items for events and retry changes, respectively. */ private val callbacks: Deque<Any> = ArrayDeque() @AfterEach fun after() { assertThat(callbacks).isEmpty() } @Test fun multiline() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/SleepNanos.kt
* See the License for the specific language governing permissions and * limitations under the License. * */ package mockwebserver3.internal internal fun sleepNanos(nanos: Long) { val ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) if (ms > 0L || nanos > 0) { Thread.sleep(ms, ns.toInt()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 811 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
bitCount += CODE_BIT_COUNTS[byteIn].toLong() } return ((bitCount + 7) shr 3).toInt() // Round up to an even byte. } fun decode( source: BufferedSource, byteCount: Long, sink: BufferedSink, ) { var node = root var accumulator = 0 var accumulatorBitCount = 0 for (i in 0 until byteCount) { val byteIn = source.readByte() and 0xff
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.3K bytes - Viewed (0) -
okhttp-dnsoverhttps/api/okhttp-dnsoverhttps.api
public static final field MAX_RESPONSE_SIZE I public final fun client ()Lokhttp3/OkHttpClient; public final fun includeIPv6 ()Z public fun lookup (Ljava/lang/String;)Ljava/util/List; public final fun post ()Z public final fun resolvePrivateAddresses ()Z public final fun resolvePublicAddresses ()Z public final fun url ()Lokhttp3/HttpUrl; }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 27 15:23:43 GMT 2022 - 1.5K bytes - Viewed (0) -
native-image-tests/src/main/kotlin/okhttp3/TestRegistration.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import com.oracle.svm.core.annotate.AutomaticFeature import java.io.File import java.lang.IllegalStateException import org.graalvm.nativeimage.hosted.Feature import org.graalvm.nativeimage.hosted.RuntimeClassInitialization import org.graalvm.nativeimage.hosted.RuntimeReflection @AutomaticFeature
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.7K bytes - Viewed (0) -
samples/guide/src/test/kotlin/okhttp3/AllMainsTest.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.File import java.lang.reflect.InvocationTargetException import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} /** * Wait a duration in nanoseconds. Unlike [java.lang.Object.wait] this interprets 0 as * "don't wait" instead of "wait forever". */ @Throws(InterruptedException::class) @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN") override fun coordinatorWait( taskRunner: TaskRunner, nanos: Long, ) { taskRunner.lock.assertHeld() if (nanos > 0) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0)