- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 38 for Farries (0.15 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt
interface ExchangeCodec { /** The connection or CONNECT tunnel that owns this codec. */ val carrier: Carrier /** Returns true if the response body and (possibly empty) trailers have been received. */ val isResponseComplete: Boolean /** The socket that carries this exchange. */ val socket: Socket /** Returns an output stream where the request body can be streamed. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 3.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/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. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 1.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = () -> { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); }; for (int j = 0; j < 10; j++) { executor.execute(wrapper); } barrier.await(); // release the threads! barrier.await(); // wait for them all to complete
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.5K bytes - Click Count (0) -
cmd/xl-storage-format-v1.go
import ( "encoding/binary" "encoding/hex" "encoding/json" "fmt" "time" "github.com/cespare/xxhash/v2" jsoniter "github.com/json-iterator/go" ) // XL constants. const ( // XL metadata file carries per object metadata. xlStorageFormatFileV1 = "xl.json" ) // Valid - tells us if the format is sane by validating // format version and erasure coding information. func (m *xlMetaV1Object) valid() bool {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 22 15:30:50 GMT 2024 - 8.4K bytes - Click Count (0) -
docs/contribute/concurrency.md
* **Exchange** carries a single HTTP request/response pair. * **ExchangeFinder** chooses which connection carries each exchange. Where possible it will use the same connection for all exchanges in a single call. It prefers reusing pooled connections over establishing new connections.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
import okio.Sink import okio.Socket 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 =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 7K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/RequestTrace.java
* supports the following key features: * * <ul> * <li>Maintains parent-child relationships between requests to track operation nesting</li> * <li>Carries contextual data describing the current request or operation</li> * <li>Supports both internal session operations and client-provided trace information</li> * </ul> *
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 2.9K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt
*/ package mockwebserver3 /** * An adverse action to take on a socket, intended to exercise failure modes in the calling code. */ public sealed interface SocketEffect { /** * Close the TCP socket that carries this request. * * Using this as [MockResponse.onResponseEnd] is the default for HTTP/1.0. */ public class CloseSocket( public val closeSocket: Boolean = true, public val shutdownInput: Boolean = false,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 1.6K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsProblem.java
package org.apache.maven.settings.building; /** * Describes a problem that was encountered during settings building. A problem can either be an exception that was * thrown or a simple string message. In addition, a problem carries a hint about its source, e.g. the settings file * that exhibits the problem. * * @deprecated since 4.0.0, use {@link org.apache.maven.api.services.SettingsBuilder} instead */ @Deprecated(since = "4.0.0")Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Jul 23 17:27:08 GMT 2025 - 4.4K bytes - Click Count (0) -
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/PropertyContributor.java
* * @since 4.0.0 */ @Experimental @Consumer @Named public interface PropertyContributor extends SpiService { /** * Invoked just before session is created with a mutable map that carries collected user properties so far. * * @param userProperties The mutable user properties, never {@code null}. * @see #contribute(ProtoSession) */Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Nov 20 19:58:27 GMT 2024 - 2.3K bytes - Click Count (0)