- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getEvents (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)