- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 942 for Dedent (0.04 sec)
-
guava/src/com/google/common/eventbus/Subscribe.java
- import java.lang.annotation.Target;
- /**
- * Marks a method as an event subscriber.
- *
- * <p>The type of event will be indicated by the method's first (and only) parameter, which cannot
- * be primitive. If this annotation is applied to methods with zero parameters, or more than one
- * parameter, the object containing the method will not be able to register for event delivery from
- * the {@link EventBus}.
- *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 1.5K bytes - Viewed (0) -
docs/select/select.py
- },
- 'CompressionType': 'GZIP',
- },
- OutputSerialization={'CSV': {}},
- )
- for event in r['Payload']:
- if 'Records' in event:
- records = event['Records']['Payload'].decode('utf-8')
- print(records)
- elif 'Stats' in event:
- statsDetails = event['Stats']['Details']
- print("Stats details bytesScanned: ")
- print(statsDetails['BytesScanned'])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 18 00:11:39 UTC 2018 - 1K bytes - Viewed (0) -
internal/event/target/amqp.go
- func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
- var queueStore store.Store[event.Event]
- if args.QueueDir != "" {
- queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
- queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
- if err := queueStore.Open(); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
- try {
- while (true) {
- val event = takeEvent()
- if (eventClass.isInstance(event)) {
- return eventClass.cast(event)
- }
- }
- } catch (e: NoSuchElementException) {
- throw AssertionError("full event sequence: $fullEventSequence", e)
- }
- }
- /**
- * Remove and return the next event from the recorded sequence.
- *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java
- }
- public void testAnnotatedIn1() {
- assertThat(getSubscriber().annotatedIn1Events).contains(EVENT);
- }
- public void testAnnotatedIn2() {
- assertThat(getSubscriber().annotatedIn2Events).contains(EVENT);
- }
- public void testAnnotatedIn1And2() {
- assertThat(getSubscriber().annotatedIn1And2Events).contains(EVENT);
- }
- public void testAnnotatedIn1And2AndClass() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 08 21:35:40 UTC 2022 - 4.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/ActivityHelperTest.java
- activityHelper.login(OptionalThing.empty());
- assertEquals(
- "{\"@timestamp\":\"2022-01-01T00:00:00.000Z\",\"log.level\":\"INFO\",\"ecs.version\":\"1.2.0\",\"service.name\":\"fess\",\"event.dataset\":\"app\",\"process.thread.name\":\"main\",\"log.logger\":\"org.codelibs.fess.helper.ActivityHelperTest$1\",\"labels.action\":\"LOGIN\",\"labels.user\":\"-\",\"labels.permissions\":\"-\"}",
- localLogMsg.get());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.1K bytes - Viewed (0) -
docs_src/websockets/tutorial001.py
- var content = document.createTextNode(event.data)
- message.appendChild(content)
- messages.appendChild(message)
- };
- function sendMessage(event) {
- var input = document.getElementById("messageText")
- ws.send(input.value)
- input.value = ''
- event.preventDefault()
- }
- </script>
- </body>
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 1.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/scope/internal/MojoExecutionScope.java
- }
- public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException {
- for (WeakMojoExecutionListener provided : getProvidedListeners()) {
- provided.beforeMojoExecution(event);
- }
- }
- public void afterMojoExecutionSuccess(MojoExecutionEvent event) throws MojoExecutionException {
- for (WeakMojoExecutionListener provided : getProvidedListeners()) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.3K bytes - Viewed (0) -
docs_src/websockets/tutorial003_py39.py
- ws.onmessage = function(event) {
- var messages = document.getElementById('messages')
- var message = document.createElement('li')
- var content = document.createTextNode(event.data)
- message.appendChild(content)
- messages.appendChild(message)
- };
- function sendMessage(event) {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
- *
- * @param identifier short name for the bus, for logging purposes.
- * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
- * down the executor after the last event has been posted to this event bus.
- */
- public AsyncEventBus(String identifier, Executor executor) {
- super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE);
- }
- /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 2.5K bytes - Viewed (0)