Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getEvents (1.3 sec)

  1. android/guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java

        StringCatcher catcher = new StringCatcher();
        bus.register(catcher);
    
        // We post the event, but our Executor will not deliver it until instructed.
        bus.post(EVENT);
    
        List<String> events = catcher.getEvents();
        assertTrue("No events should be delivered synchronously.", events.isEmpty());
    
        // Now we find the task in our Executor and explicitly activate it.
        List<Runnable> tasks = executor.getTasks();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/evaluator_test.go

    		}
    		objs = append(objs, obj)
    	}
    	now := time.Date(2025, time.February, 10, 23, 0, 0, 0, time.UTC)
    	gotEvents := evaluator.eval(objs, now)
    	for i := range wantEvents {
    		if gotEvents[i].Action != wantEvents[i].Action {
    			t.Fatalf("got %v, want %v", gotEvents[i], wantEvents[i])
    		}
    	}
    
    	lc = prepLifecycleCfg([]string{"tag3", "tag4", "tag5"}, []int{1, 2, 3})
    	objs = objs[:len(objs)-1]
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 08 15:41:24 UTC 2025
    - 5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java

       * a new event based on the error.
       */
      public EventBus getEventBus() {
        return eventBus;
      }
    
      /** Returns the event object that caused the subscriber to throw. */
      public Object getEvent() {
        return event;
      }
    
      /** Returns the object context that the subscriber was called on. */
      public Object getSubscriber() {
        return subscriber;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/eventbus/DeadEvent.java

      }
    
      /**
       * Returns the wrapped, 'dead' event, which the system was unable to deliver to any registered
       * subscriber.
       *
       * @return the 'dead' event that could not be delivered.
       */
      public Object getEvent() {
        return event;
      }
    
      @Override
      public String toString() {
        return MoreObjects.toStringHelper(this).add("source", source).add("event", event).toString();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. cmd/os_unix.go

    	}
    
    	return nil
    }
    
    // The buffer must be at least a block long.
    // refer https://github.com/golang/go/issues/24015
    const blockSize = 8 << 10 // 8192
    
    // By default at least 128 entries in single getdents call (1MiB buffer)
    var (
    	direntPool = bpool.Pool[*[]byte]{
    		New: func() *[]byte {
    			buf := make([]byte, blockSize*128)
    			return &buf
    		},
    	}
    
    	direntNamePool = bpool.Pool[*[]byte]{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  6. api/go1.txt

    pkg syscall (linux-386), func Futimes(int, []Timeval) error
    pkg syscall (linux-386), func Futimesat(int, string, []Timeval) error
    pkg syscall (linux-386), func Getcwd([]uint8) (int, error)
    pkg syscall (linux-386), func Getdents(int, []uint8) (int, error)
    pkg syscall (linux-386), func Getpeername(int) (Sockaddr, error)
    pkg syscall (linux-386), func Getpgid(int) (int, error)
    pkg syscall (linux-386), func Getpgrp() int
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  7. api/go1.2.txt

    pkg syscall (linux-arm-cgo), func Futimesat(int, string, []Timeval) error
    pkg syscall (linux-arm-cgo), func Getcwd([]uint8) (int, error)
    pkg syscall (linux-arm-cgo), func Getdents(int, []uint8) (int, error)
    pkg syscall (linux-arm-cgo), func Getpeername(int) (Sockaddr, error)
    pkg syscall (linux-arm-cgo), func Getpgid(int) (int, error)
    pkg syscall (linux-arm-cgo), func Getpgrp() int
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 18 04:36:59 UTC 2013
    - 1.9M bytes
    - Viewed (1)
Back to top