- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for Carrie (0.2 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
import okio.Sink import okio.Source /** Encodes HTTP requests and decodes HTTP responses. */ interface ExchangeCodec { /** The connection or CONNECT tunnel that owns this codec. */ val carrier: Carrier /** Returns an output stream where the request body can be streamed. */ @Throws(IOException::class) fun createRequestBody( request: Request, contentLength: Long, ): Sink
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
private var refusedStreamCount = 0 /** * The maximum number of concurrent streams that can be carried by this connection. If * `allocations.size() < allocationLimit` then new streams can be created on this connection. */ internal var allocationLimit = 1 private set /** Current calls carried by this connection. */ val calls = mutableListOf<Reference<RealCall>>()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} final CyclicBarrier barrier = new CyclicBarrier( 6 // for the setter threads + 50 // for the listeners + 50 // for the blocking get threads, + 1); // for the main thread final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} }); final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } }; for (int j = 0; j < 10; j++) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} final CyclicBarrier barrier = new CyclicBarrier( 6 // for the setter threads + 50 // for the listeners + 50 // for the blocking get threads, + 1); // for the main thread final ExecutorService executor = Executors.newFixedThreadPool(barrier.getParties());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
internal var hasFailure: Boolean = false private set internal val connection: RealConnection get() = codec.carrier as? RealConnection ?: error("no connection for CONNECT tunnels") internal val isCoalescedConnection: Boolean get() = finder.routePlanner.address.url.host != codec.carrier.route.address.url.host @Throws(IOException::class) fun writeRequestHeaders(request: Request) { try {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} }); final CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } }; for (int j = 0; j < 10; j++) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
*/ class Http1ExchangeCodec( /** The client that configures this stream. May be null for HTTPS proxy tunnels. */ private val client: OkHttpClient?, override val carrier: ExchangeCodec.Carrier, private val source: BufferedSource, private val sink: BufferedSink, ) : ExchangeCodec { private var state = STATE_IDLE private val headersReader = HeadersReader(source)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
import okhttp3.internal.immutableListOf import okio.Sink import okio.Source /** Encode requests and responses using HTTP/2 frames. */ class Http2ExchangeCodec( client: OkHttpClient, override val carrier: Carrier, private val chain: RealInterceptorChain, private val http2Connection: Http2Connection, ) : ExchangeCodec { @Volatile private var stream: Http2Stream? = null private val protocol: Protocol =
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) /** * Notification that the receiving connection flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0)