Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 942 for Dedent (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top