- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 50 for Kistner (0.27 sec)
-
okhttp/src/test/java/okhttp3/DispatcherTest.kt
val dispatcher = Dispatcher(executor) val listener = RecordingEventListener() var client = clientTestRule.newClientBuilder() .dns { throw UnknownHostException() } .dispatcher(dispatcher) .eventListenerFactory(clientTestRule.wrap(listener)) .build() @BeforeEach fun setUp() { dispatcher.maxRequests = 20 dispatcher.maxRequestsPerHost = 10 listener.forbidLock(dispatcher) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import okio.IOException /** * Listener for connection events. Extend this class to monitor the new connections and closes. * * All event methods must execute fast, without external locking, cannot throw exceptions,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server1: MockWebServer private lateinit var server2: MockWebServer private var listener = RecordingEventListener() private val handshakeCertificates = platform.localhostHandshakeCertificates() val dns = FakeDns() val ipv4 = InetAddress.getByName("203.0.113.1")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
server.close(1000, null) serverListener.assertClosed(1000, "goodbye") } @Test fun webSocketsDontTriggerEventListener() { val listener = RecordingEventListener() client = client.newBuilder() .eventListenerFactory(clientTestRule.wrap(listener)) .build() webServer.enqueue( MockResponse.Builder() .webSocketUpgrade(serverListener) .build(), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
peer.play() // Play it back. val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(peer.openSocket()) .pushObserver(Http2ConnectionTest.IGNORE) .listener(realConnection) .build() connection.start(sendConnectionPreface = false) // verify the peer received the ACK val ackFrame = peer.takeFrame()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/http2/Http2Connection$Builder;-><init>(ZLokhttp3/internal/concurrent/TaskRunner;)V HSPLokhttp3/internal/http2/Http2Connection$Listener$Companion$REFUSE_INCOMING_STREAMS$1;-><init>()V HSPLokhttp3/internal/http2/Http2Connection$Listener;-><clinit>()V HSPLokhttp3/internal/http2/Http2Connection$Listener;-><init>()V
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
hand it off to another thread to write to it after `writeTo` returns. The `EventListener` may now see requests and responses interleaved in ways not previously permitted. For example, a listener may receive `responseHeadersStart()` followed by `requestBodyEnd()`, both on the same call. Such events may be triggered by different threads even for a single call.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
// Confirm the events occur when expected. listener.takeEvent(CallStart::class.java, 0L) listener.takeEvent(ConnectionAcquired::class.java, applicationInterceptorDelay) listener.takeEvent(RequestHeadersStart::class.java, networkInterceptorDelay) listener.takeEvent(RequestHeadersEnd::class.java, 0L) listener.takeEvent(RequestBodyStart::class.java, 0L) listener.takeEvent(RequestBodyEnd::class.java, requestBodyDelay)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
val response = call.execute() assertThat(response.code).isEqualTo(200) response.body.close() listener.removeUpToEvent(ConnectionEvent.ConnectEnd::class.java) listener.removeUpToEvent(ConnectionEvent.ConnectionReleased::class.java) listener.removeUpToEvent(ConnectionEvent.ConnectionAcquired::class.java) listener.removeUpToEvent(ConnectionEvent.ConnectionReleased::class.java) } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.6K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
Listener listener; synchronized (this) { listener = listeners.get(state); } if (code == null || listener == null) { return new MockResponse() .setResponseCode(404) .setBody("unexpected request"); } try { OAuthSession session = slackApi.exchangeCode(code, redirectUrl()); listener.sessionGranted(session);
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Viewed (0)