Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,230 for event (0.03 sec)

  1. okhttp-sse/src/test/java/okhttp3/sse/internal/Event.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.sse.internal
    
    internal data class Event(
      val id: String?,
      val type: String?,
      val data: String,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 23 10:26:25 UTC 2023
    - 720 bytes
    - Viewed (0)
  2. cmd/event-notification.go

    	if escape {
    		keyName = url.QueryEscape(args.Object.Name)
    	}
    
    	newEvent := event.Event{
    		EventVersion:      "2.0",
    		EventSource:       "minio:s3",
    		AwsRegion:         args.ReqParams["region"],
    		EventTime:         eventTime.Format(event.AMZTimeFormat),
    		EventName:         args.EventName,
    		UserIdentity:      event.Identity{PrincipalID: args.ReqParams["principalId"]},
    		RequestParameters: args.ReqParams,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/events.md

    You can add more than one event handler function.
    
    And your application won't start receiving requests until all the `startup` event handlers have completed.
    
    ### `shutdown` event
    
    To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`:
    
    {* ../../docs_src/events/tutorial002.py hl[6] *}
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. guava/src/com/google/common/eventbus/Dispatcher.java

          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()) {
            dispatching.set(true);
            try {
              Event nextEvent;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  5. internal/event/target/kafka.go

    func (target *KafkaTarget) SendFromStore(key store.Key) (err error) {
    	if err = target.init(); err != nil {
    		return err
    	}
    	switch {
    	case key.ItemCount == 1:
    		var event event.Event
    		event, err = target.store.Get(key)
    		if err != nil {
    			// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyExecutionListener.java

        }
    
        @Override
        public void projectSkipped(ExecutionEvent event) {
            dispatcher.onEvent(event);
            delegate.projectSkipped(event);
        }
    
        @Override
        public void projectStarted(ExecutionEvent event) {
            dispatcher.onEvent(event);
            delegate.projectStarted(event);
        }
    
        @Override
        public void projectSucceeded(ExecutionEvent event) {
            dispatcher.onEvent(event);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. internal/event/target/nsq.go

    }
    
    // send - sends an event to the NSQ.
    func (target *NSQTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt

      }
    
      @Test
      fun idCleared() {
        consumeEvents(
          """
          |data: first event
          |id: 1
          |
          |data: second event
          |id
          |
          |data: third event
          |
          |
          """.trimMargin(),
        )
        assertThat(callbacks.remove()).isEqualTo(Event("1", null, "first event"))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

            ongoing.remove(new TransferResourceIdentifier(event.getResource()));
            put(event, ongoing.isEmpty());
        }
    
        private static class Exchange {
            private final TransferEvent event;
    
            private Exchange(TransferEvent event) {
                this.event = event;
            }
    
            public void process(Consumer<TransferEvent> consumer) {
                consumer.accept(event);
            }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/execution/ExecutionListener.java

        void projectDiscoveryStarted(ExecutionEvent event);
    
        void sessionStarted(ExecutionEvent event);
    
        void sessionEnded(ExecutionEvent event);
    
        void projectSkipped(ExecutionEvent event);
    
        void projectStarted(ExecutionEvent event);
    
        void projectSucceeded(ExecutionEvent event);
    
        void projectFailed(ExecutionEvent event);
    
        void mojoSkipped(ExecutionEvent event);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top