Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 233 for Event (0.08 seconds)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt

      ) : CallEvent() {
        override fun closes(event: CallEvent): Boolean = event is CallStart && call == event.call
      }
    
      data class CallFailed(
        override val timestampNs: Long,
        override val call: Call,
        val ioe: IOException,
      ) : CallEvent() {
        override fun closes(event: CallEvent): Boolean = event is CallStart && call == event.call
      }
    
      data class Canceled(
        override val timestampNs: Long,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Oct 06 13:40:20 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/eventbus/Dispatcher.java

              }
            };
    
        @Override
        void dispatch(Object event, Iterator<Subscriber> subscribers) {
          checkNotNull(event);
          checkNotNull(subscribers);
          // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get
          Queue<Event> queueForThread = requireNonNull(queue.get());
          queueForThread.offer(new Event(event, subscribers));
    
          if (!dispatching.get()) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  3. internal/event/target/nsq.go

    func NewNSQTarget(id string, args NSQArgs, loggerOnce logger.LogOnce) (*NSQTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-nsq-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  4. internal/bucket/lifecycle/evaluator.go

    				event = Event{}
    			}
    
    			if e.IsPendingReplication(obj) {
    				event = Event{}
    			}
    		}
    		if !obj.IsLatest {
    			switch event.Action {
    			case DeleteVersionAction:
    				// this noncurrent version will be expired, nothing to add
    			default:
    				// this noncurrent version will be spared
    				newerNoncurrentVersions++
    			}
    		}
    		events[i] = event
    	}
    	return events
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 08 15:41:24 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  5. impl/maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java

    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

      }
    
      /**
       * Enqueues an event to be run on currently known listeners.
       *
       * <p>The {@code toString} method of the Event itself will be used to describe the event in the
       * case of an error.
       *
       * @param event the callback to execute on {@link #dispatch}
       */
      public void enqueue(Event<L> event) {
        enqueueHelper(event, event);
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  7. internal/event/target/mysql.go

    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  8. guava/src/com/google/common/eventbus/Subscriber.java

        this.executor = bus.executor();
      }
    
      /** Dispatches {@code event} to this subscriber using the proper executor. */
      final void dispatchEvent(Object event) {
        executor.execute(
            () -> {
              try {
                invokeSubscriberMethod(event);
              } catch (InvocationTargetException e) {
                bus.handleSubscriberException(e.getCause(), context(event));
              }
            });
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  9. compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/util/ConsoleRepositoryListener.java

            println("artifactInstalling", event.getArtifact() + " to " + event.getFile());
        }
    
        @Override
        public void artifactResolved(RepositoryEvent event) {
            println("artifactResolved", event.getArtifact() + " from " + event.getRepository());
        }
    
        @Override
        public void artifactDownloading(RepositoryEvent event) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  10. internal/event/config_test.go

    	dataCase1 := []byte(`
    <QueueConfiguration>
       <Id>1</Id>
       <Filter></Filter>
       <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue>
       <Event>s3:ObjectAccessed:*</Event>
       <Event>s3:ObjectCreated:*</Event>
       <Event>s3:ObjectRemoved:*</Event>
    </QueueConfiguration>`)
    
    	dataCase2 := []byte(`
    <QueueConfiguration>
       <Id>1</Id>
        <Filter>
            <S3Key>
                <FilterRule>
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 28.9K bytes
    - Click Count (0)
Back to Top