Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. guava/src/com/google/common/eventbus/Subscribe.java

    1. import java.lang.annotation.Target;
    2.  
    3. /**
    4. * Marks a method as an event subscriber.
    5. *
    6. * <p>The type of event will be indicated by the method's first (and only) parameter, which cannot
    7. * be primitive. If this annotation is applied to methods with zero parameters, or more than one
    8. * parameter, the object containing the method will not be able to register for event delivery from
    9. * the {@link EventBus}.
    10. *
    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

    1. },
    2. 'CompressionType': 'GZIP',
    3. },
    4. OutputSerialization={'CSV': {}},
    5. )
    6.  
    7. for event in r['Payload']:
    8. if 'Records' in event:
    9. records = event['Records']['Payload'].decode('utf-8')
    10. print(records)
    11. elif 'Stats' in event:
    12. statsDetails = event['Stats']['Details']
    13. print("Stats details bytesScanned: ")
    14. 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

    1. func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    2. var queueStore store.Store[event.Event]
    3. if args.QueueDir != "" {
    4. queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
    5. queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    6. 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

    1. try {
    2. while (true) {
    3. val event = takeEvent()
    4. if (eventClass.isInstance(event)) {
    5. return eventClass.cast(event)
    6. }
    7. }
    8. } catch (e: NoSuchElementException) {
    9. throw AssertionError("full event sequence: $fullEventSequence", e)
    10. }
    11. }
    12.  
    13. /**
    14. * Remove and return the next event from the recorded sequence.
    15. *
    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. android/guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java

    1. }
    2.  
    3. public void testAnnotatedIn1() {
    4. assertThat(getSubscriber().annotatedIn1Events).contains(EVENT);
    5. }
    6.  
    7. public void testAnnotatedIn2() {
    8. assertThat(getSubscriber().annotatedIn2Events).contains(EVENT);
    9. }
    10.  
    11. public void testAnnotatedIn1And2() {
    12. assertThat(getSubscriber().annotatedIn1And2Events).contains(EVENT);
    13. }
    14.  
    15. 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)
  6. src/test/java/org/codelibs/fess/helper/ActivityHelperTest.java

    1. activityHelper.login(OptionalThing.empty());
    2. assertEquals(
    3. "{\"@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\":\"-\"}",
    4. 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)
  7. docs_src/websockets/tutorial001.py

    1. var content = document.createTextNode(event.data)
    2. message.appendChild(content)
    3. messages.appendChild(message)
    4. };
    5. function sendMessage(event) {
    6. var input = document.getElementById("messageText")
    7. ws.send(input.value)
    8. input.value = ''
    9. event.preventDefault()
    10. }
    11. </script>
    12. </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

    1. }
    2.  
    3. public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException {
    4. for (WeakMojoExecutionListener provided : getProvidedListeners()) {
    5. provided.beforeMojoExecution(event);
    6. }
    7. }
    8.  
    9. public void afterMojoExecutionSuccess(MojoExecutionEvent event) throws MojoExecutionException {
    10. 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

    1. ws.onmessage = function(event) {
    2. var messages = document.getElementById('messages')
    3. var message = document.createElement('li')
    4. var content = document.createTextNode(event.data)
    5. message.appendChild(content)
    6. messages.appendChild(message)
    7. };
    8. 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

    1. *
    2. * @param identifier short name for the bus, for logging purposes.
    3. * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
    4. * down the executor after the last event has been posted to this event bus.
    5. */
    6. public AsyncEventBus(String identifier, Executor executor) {
    7. super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE);
    8. }
    9.  
    10. /**
    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