Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for listenCh (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/main/java/jcifs/internal/witness/WitnessClient.java

                    WitnessNotificationListener listener = listeners.get(entry.getKey());
                    if (listener != null) {
                        try {
                            listener.onWitnessNotification(notification);
                        } catch (Exception e) {
                            log.error("Error in witness notification listener", e);
                        }
                    }
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
Back to top