- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,230 for event (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)