Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 272 for eventbus (0.2 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(ackFrame.ack).isTrue()
        return connection
      }
    
      private class RecordingPushObserver : PushObserver {
        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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  2. .github/workflows/codeql.yml

        runs-on: ${{ (matrix.language == 'swift' && 'macos-latest') || 'ubuntu-latest' }}
        timeout-minutes: ${{ (matrix.language == 'swift' && 120) || 360 }}
        permissions:
          # required for all workflows
          security-events: write
    
          # required to fetch internal or private CodeQL packs
          packages: read
    
          # only required for workflows in private repositories
          actions: read
          contents: read
    
        strategy:
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Aug 14 23:51:19 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

    import java.util.ArrayDeque
    import java.util.Deque
    import okio.Buffer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    class ServerSentEventIteratorTest {
      /** Either [Event] or [Long] items for events and retry changes, respectively.  */
      private val callbacks: Deque<Any> = ArrayDeque()
    
      @AfterEach
      fun after() {
        assertThat(callbacks).isEmpty()
      }
    
      @Test
      fun multiline() {
        consumeEvents(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. 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 Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  5. docs/bucket/lifecycle/DESIGN.md

    ### Expiry or removal events
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  6. internal/pubsub/pubsub.go

    	sync.RWMutex
    }
    
    // Publish message to the subscribers.
    // Note that publish is always non-blocking send so that we don't block on slow receivers.
    // Hence receivers should use buffered channel so as not to miss the published events.
    func (ps *PubSub[T, M]) Publish(item T) {
    	ps.RLock()
    	defer ps.RUnlock()
    	for _, sub := range ps.subs {
    		if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) {
    			select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. cmd/iam-etcd-store.go

    		err = errNoSuchGroup
    	}
    	return err
    }
    
    func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent {
    	ch := make(chan iamWatchEvent)
    
    	// go routine to read events from the etcd watch channel and send them
    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  8. internal/event/target/elasticsearch.go

    	defer cancel()
    
    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return false, err
    	}
    
    	return target.client.ping(ctx, target.args)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active.
    func (target *ElasticsearchTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.29.md

    - `kubectl` will not print events if `--show-events=false` argument is passed to
      describe PVC subcommand. ([#120380](https://github.com/kubernetes/kubernetes/pull/120380), [@MaGaroo](https://github.com/MaGaroo))
    - `scheduler`: Fixed missing field `apiVersion` from events reported by the taint
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:37:31 UTC 2024
    - 375.1K bytes
    - Viewed (1)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

     * on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow
     * output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even
     * concurrently.
     *
     * @since 4.0.0
     */
    public final class SimplexTransferListener extends AbstractTransferListener {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top