- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 206 for carlie (0.19 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 19 11:42:09 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 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 15.2K bytes - Viewed (0) -
cmd/storage-datatypes.go
FSType string RootDisk bool Healing bool Scanning bool Endpoint string MountPath string ID string Rotational bool Metrics DiskMetrics Error string // carries the error over the network } // DiskMetrics has the information about XL Storage APIs // the number of calls of each API and the moving average of // the duration of each API. type DiskMetrics struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:41:27 GMT 2024 - 14.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/toolchain/java/DefaultJavaToolChain.java
/** * Provides backwards compatibility with Maven 3.2.3 and earlier. Clients that do not require compatibility with Maven * 3.2.3 and earlier are encouraged to use {@link JavaToolchainImpl}. * <strong>Note:</strong> This is an internal component whose interface can change without prior notice. * * @deprecated clients that do not require compatibility with Maven 3.2.3 and earlier should link to * {@link JavaToolchainImpl} instead. */
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Tue Feb 07 19:46:28 GMT 2023 - 1.8K bytes - Viewed (0) -
docs/features/events.md
long callId = nextCallId.getAndIncrement(); System.out.printf("%04d %s%n", callId, call.request().url()); return new PrintingEventListener(callId, System.nanoTime()); } }; final long callId; final long callStartNanos; public PrintingEventListener(long callId, long callStartNanos) { this.callId = callId; this.callStartNanos = callStartNanos; }
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
* servers {@code alpha}, {@code bravo}, and {@code charlie} and you occasionally need to * take each of the servers offline, {@code consistentHash} will be a poor fit: It provides * no way for you to specify which of the three buckets is disappearing. Thus, if your * buckets change from {@code [alpha, bravo, charlie]} to {@code [bravo, charlie]}, it will
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Apr 09 00:37:15 GMT 2024 - 29.2K 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 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java
long callId = nextCallId.getAndIncrement(); System.out.printf("%04d %s%n", callId, call.request().url()); return new PrintingEventListener(callId, System.nanoTime()); } }; final long callId; final long callStartNanos; PrintingEventListener(long callId, long callStartNanos) { this.callId = callId; this.callStartNanos = callStartNanos; }
Java - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 6.1K 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 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
doc/next/6-stdlib/1-time.md
[time.Timer] and [time.Ticker]. First, `Timer`s and `Ticker`s that are no longer referred to by the program become eligible for garbage collection immediately, even if their `Stop` methods have not been called. Earlier versions of Go did not collect unstopped `Timer`s until after they had fired and never collected unstopped `Ticker`s. Second, the timer channel associated with a `Timer` or `Ticker` is now unbuffered, with capacity 0.
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Apr 12 20:57:18 GMT 2024 - 1.5K bytes - Viewed (0)