- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 648 for connecting (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
printEvent("connectFailed"); } @Override public void connectionAcquired(Call call, Connection connection) { printEvent("connectionAcquired"); } @Override public void connectionReleased(Call call, Connection connection) { printEvent("connectionReleased"); } @Override public void requestHeadersStart(Call call) { printEvent("requestHeadersStart"); }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 5.3K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
) override fun connectEnd( connection: Connection, route: Route, call: Call, ) { logEvent(ConnectionEvent.ConnectEnd(System.nanoTime(), connection, route, call)) } override fun connectionClosed(connection: Connection) = logEvent(ConnectionEvent.ConnectionClosed(System.nanoTime(), connection)) override fun connectionAcquired(Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 5.8K bytes - Click Count (0) -
src/test/java/jcifs/http/NtlmHttpURLConnectionTest.java
private final List<HttpURLConnection> connections = new ArrayList<>(); private int currentIndex = 0; void addConnection(HttpURLConnection conn) { connections.add(conn); } @Override protected URLConnection openConnection(URL u) throws IOException { if (currentIndex < connections.size()) { return connections.get(currentIndex++);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 12.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
import okhttp3.internal.isHealthy import okhttp3.internal.tls.OkHostnameVerifier import okio.Buffer /** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection internal constructor( val taskRunner: TaskRunner,
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
internal/grid/manager.go
// ValidateAuthFn should check authentication for the given aud. type ValidateAuthFn func(auth string) string // Connection will return the connection for the specified host. // If the host does not exist nil will be returned. func (m *Manager) Connection(host string) *Connection { return m.targets[host] } // RegisterSingleHandler will register a stateless handler that serves
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Nov 12 20:41:41 GMT 2024 - 10.8K bytes - Click Count (0) -
src/main/java/jcifs/http/NtlmHttpURLConnection.java
/** * Creates a new NTLM HTTP URL connection that wraps an existing HTTP connection. * * @param connection * connection to wrap * @param tc * context to use */ public NtlmHttpURLConnection(final HttpURLConnection connection, final CIFSContext tc) { super(connection.getURL()); this.connection = connection; this.transportContext = tc;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 25.6K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt
) { logWithTime("connectFailed: $protocol $ioe") } override fun connectionAcquired( call: Call, connection: Connection, ) { logWithTime("connectionAcquired: $connection") } override fun connectionReleased( call: Call, connection: Connection, ) { logWithTime("connectionReleased") } override fun requestHeadersStart(call: Call) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 5.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTreeHandleInternal.java
* Gets the send buffer size of the underlying SMB connection * @return the send buffer size of the underlying connection * @throws CIFSException if an error occurs retrieving the buffer size */ int getSendBufferSize() throws CIFSException; /** * Gets the receive buffer size of the underlying SMB connection * @return the receive buffer size of the underlying connectionCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
response.body.close() assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "ConnectionReleased", ) val event = listener.removeUpToEvent(ConnectionEvent.ConnectEnd::class.java) assertThat(event.connection.route().proxy).isEqualTo(proxy) } private fun enableTls() { client = client .newBuilder()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 9.7K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
override val timestampNs: Long, override val connection: Connection, ) : ConnectionEvent() data class ConnectionAcquired( override val timestampNs: Long, override val connection: Connection, val call: Call, ) : ConnectionEvent() data class ConnectionReleased( override val timestampNs: Long, override val connection: Connection, val call: Call, ) : ConnectionEvent() {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri May 30 21:28:20 GMT 2025 - 2.6K bytes - Click Count (0)