Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 295 for eventbus (0.07 sec)

  1. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        cancelLatch.await()
    
        val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name }
        listener.clearAllEvents()
    
        assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired")
        if (cancelMode == CANCEL) {
          assertThat(events).contains("Canceled")
        } else {
          assertThat(events).doesNotContain("Canceled")
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. cmd/bootstrap-messages.go

    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. impl/maven-core/src/main/java/org/apache/maven/execution/ExecutionListener.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.execution;
    
    /**
     * Defines events that Maven fires during a build. <strong>Warning:</strong> This interface might be extended in future
     * Maven versions to support further events. Hence it is strongly recommended to derive custom listeners from
     * {@link AbstractExecutionListener} in order to avoid interoperability problems.
     *
     */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  4. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.collect-failed-tasks.gradle.kts

     */
    import gradlebuild.AbstractBuildScanInfoCollectingService
    import gradlebuild.registerBuildScanInfoCollectingService
    import io.gitlab.arturbosch.detekt.Detekt
    import org.gradle.tooling.events.task.TaskFailureResult
    import org.gradle.tooling.events.task.TaskOperationResult
    import java.io.Serializable
    import java.util.concurrent.CopyOnWriteArrayList
    
    /**
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Jun 20 08:07:01 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. cni/pkg/util/pluginutil.go

    	"istio.io/istio/pkg/log"
    )
    
    type Watcher struct {
    	watcher *fsnotify.Watcher
    	Events  chan struct{}
    	Errors  chan error
    }
    
    // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error
    func (w *Watcher) Wait(ctx context.Context) error {
    	select {
    	case <-w.Events:
    		return nil
    	case err := <-w.Errors:
    		return err
    	case <-ctx.Done():
    		return ctx.Err()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  6. internal/logger/help.go

    			Description: "mTLS certificate key for webhook authentication",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         BatchSize,
    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for webhook targets",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  7. cni/pkg/repair/repaircontroller.go

    	queue        controllers.Queue
    	cfg          config.RepairConfig
    	events       kclient.EventRecorder
    	repairedPods map[types.NamespacedName]types.UID
    }
    
    func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) {
    	c := &Controller{
    		cfg:          cfg,
    		client:       client,
    		events:       kclient.NewEventRecorder(client, "cni-repair"),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/AbstractBuildScanInfoCollectingService.kt

    import org.gradle.api.services.BuildService
    import org.gradle.api.services.BuildServiceParameters
    import org.gradle.tooling.events.FinishEvent
    import org.gradle.tooling.events.OperationCompletionListener
    import org.gradle.tooling.events.task.TaskFinishEvent
    import org.gradle.tooling.events.task.TaskOperationResult
    import java.io.Serializable
    
    /**
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Aug 11 07:01:27 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  9. internal/event/target/kafka.go

    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    			return err
    		}
    		err = target.send(event)
    	case key.ItemCount > 1:
    		var events []event.Event
    		events, err = target.store.GetMultiple(key)
    		if err != nil {
    			if os.IsNotExist(err) {
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt

    import org.gradle.internal.exceptions.DefaultMultiCauseException
    import org.gradle.tooling.events.FinishEvent
    import org.gradle.tooling.events.OperationCompletionListener
    import org.gradle.tooling.events.task.TaskFailureResult
    import org.gradle.tooling.events.task.TaskFinishEvent
    import org.gradle.tooling.events.task.TaskSuccessResult
    import java.io.File
    import java.io.FileOutputStream
    import java.io.IOException
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jul 28 16:19:47 UTC 2023
    - 12.5K bytes
    - Viewed (0)
Back to top