- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for listenCh (0.04 sec)
-
docs/en/docs/advanced/behind-a-proxy.md
Probably in many cases the default will be that the proxy doesn't have a stripped path prefix. In a case like that (without a stripped path prefix), the proxy would listen on something like `https://myawesomeapp.com`, and then if the browser goes to `https://myawesomeapp.com/api/v1/app` and your server (e.g. Uvicorn) listens on `http://127.0.0.1:8000` the proxy (without a stripped path prefix) would access Uvicorn at the same path: `http://127.0.0.1:8000/api/v1/app`.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 19:34:08 UTC 2025 - 16K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
.build(), ) val request = Request.Builder().url(server.url("/")).build() val response = client.newCall(request).execute() response.processEventSource(listener) listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @Test fun cancelShortCircuits() { server.enqueue( MockResponse .Builder() .body( """
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 13:49:38 UTC 2025 - 3.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
private val call: Call?, private val request: Request, private val listener: EventSourceListener, ) : EventSource, ServerSentEventReader.Callback, Callback { constructor(call: Call, listener: EventSourceListener) : this(call, call.request(), listener) constructor(response: Response, listener: EventSourceListener) : this(null, response.request, listener) @Volatile private var canceled = false override fun onResponse(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 3.3K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
} /** * Add a listener for circuit breaker events * * @param listener the listener to add */ public void addListener(CircuitBreakerListener listener) { if (listener != null) { listeners.add(listener); } } /** * Remove a listener * * @param listener the listener to remove */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/JobExecutorTest.java
// Test adding shutdown listener AtomicBoolean shutdownCalled = new AtomicBoolean(false); ShutdownListener listener = new ShutdownListener() { @Override public void onShutdown() { shutdownCalled.set(true); } }; jobExecutor.addShutdownListener(listener); assertNotNull(jobExecutor.shutdownListener);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 9.1K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
).setHeader("content-type", "text/event-stream") .build(), ) val source = newEventSource() assertThat(source.request().url.encodedPath).isEqualTo("/") listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @RetryingTest(5) fun cancelInEventShortCircuits() { server.enqueue( MockResponse .Builder() .body( """
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 8.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/impl/ScriptExecutorTest.java
// Add shutdown listener TestShutdownListener listener = new TestShutdownListener(); scriptExecutor.addShutdownListener(listener); // Verify listener not called yet assertFalse(listener.wasShutdownCalled()); // Call shutdown scriptExecutor.shutdown(); // Verify listener was called assertTrue(listener.wasShutdownCalled());
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 10.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/witness/WitnessClientTest.java
client.processNotification(notification); // Verify notification was delivered assertTrue(listener.waitForNotification(1000)); assertNotNull(listener.getLastNotification()); assertEquals(WitnessEventType.CLIENT_MOVE, listener.getLastNotification().getEventType()); client.close(); } @Test void testUnregistration() throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 09:06:40 UTC 2025 - 9.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
assertNull(segment.refresh(key, hash, identityLoader(), false)); } // Removal listener tests public void testRemovalListener_explicit() { QueuingRemovalListener<Object, Object> listener = queuingRemovalListener(); LocalCache<Object, Object> map = makeLocalCache(createCacheBuilder().removalListener(listener)); assertTrue(listener.isEmpty()); Object one = new Object(); Object two = new Object();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 110.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 20.8K bytes - Viewed (0)