Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 147 for eventbus (0.06 sec)

  1. CHANGELOG/CHANGELOG-1.27.md

    - Fixed a bug where `events/v1` `Events` with similar event type and reporting instance were not aggregated by `client-go`. ([#112365](https://github.com/kubernetes/kubernetes/pull/112365), [@dgrisonnet](https://github.com/dgrisonnet))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (2)
  2. kotlin-js-store/yarn.lock

      integrity sha512-8guHBZCwKnFhYdHr2ysuRWErTwhoN2X8XELRlrRwpmfeY2jjuUN4taQMsULKUVo1K4DvZl+0pgfyoysHxvmvEw==
    
    events@^3.2.0:
      version "3.3.0"
      resolved "https://registry.yarnpkg.com/events/-/events-3.3.0.tgz#31a95ad0a924e2d2c419a813aeb2c4e878ea7400"
      integrity sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==
    
    extend@^3.0.0:
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        return connection
      }
    
      private class RecordingPushObserver :
        PushObserver,
        Lockable {
        val events = mutableListOf<Any>()
    
        @Synchronized fun takeEvent(): Any {
          while (events.isEmpty()) {
            wait()
          }
          return events.removeAt(0)
        }
    
        @Synchronized override fun onRequest(
          streamId: Int,
          requestHeaders: List<Header>,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        timeToFirstByte()
      }
    
      /**
       * Test to confirm that events are reported at the time they occur and no earlier and no later.
       * This inserts a bunch of synthetic 250 ms delays into both client and server and confirms that
       * the same delays make it back into the events.
       *
       * We've had bugs where we report an event when we request data rather than when the data actually
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/witness/WitnessClient.java

        private static final int DEFAULT_WITNESS_PORT = 135; // RPC endpoint mapper
    
        /**
         * Interface for receiving witness notifications and registration events.
         */
        public interface WitnessNotificationListener {
            /**
             * Called when a witness notification is received.
             *
             * @param notification the witness notification
             */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

          )
    
        call.execute().use { response ->
          assertThat(response.body.string()).isEqualTo("abc")
        }
    
        val expectedEvents = mutableListOf<KClass<out CallEvent>>()
        // Start out with standard events...
        expectedEvents += CallStart::class
        expectedEvents += ProxySelectStart::class
        expectedEvents += ProxySelectEnd::class
        expectedEvents += DnsStart::class
        expectedEvents += DnsEnd::class
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/dcerpc/msrpc/lsarpc.java

                    }
                    _src = _src.deferred;
                    this.sid.decode(_src);
    
                }
            }
        }
    
        /** Policy information class for audit events. */
        /** Policy information level for audit events. */
        public static final int POLICY_INFO_AUDIT_EVENTS = 2;
        /** Policy information class for primary domain. */
        /** Policy information level for primary domain. */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 44.5K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.32.md

    - When `SchedulerQueueingHint` is enabled,
      the scheduler's in-tree plugins now subscribe to specific node events to decide whether to requeue Pods.
      This allows the scheduler to handle cluster events faster with less memory.
    
      Specific node events include updates to taints, tolerations or allocatable.
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Tue Dec 16 18:27:41 UTC 2025
    - 448.1K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactory.java

                    throw e;
                }
            }
        }
    
        /**
         * Listener interface for handling object destruction events.
         *
         * @param <T> The type of the pooled object
         */
        @FunctionalInterface
        public interface OnDestroyListener<T> {
            /**
             * Called when a pooled object is being destroyed.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        server.requireClientAuth()
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
        assertFailsWith<IOException> {
          call.execute()
        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
        // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 13K bytes
    - Viewed (0)
Back to top