Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/AndroidKnife/RxBus
/ functions
Functions
224 in github.com/AndroidKnife/RxBus
⨍
Functions
224
◇
Types & classes
78
↓ 50 callers
Method
register
Registers all subscriber methods on {@code object} to receive events and producer methods to provide events. <p/> If any subscribers are registering f
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:173
↓ 32 callers
Method
get
Get the instance of {@link Bus} @return
rxbus/src/main/java/com/hwangjr/rxbus/RxBus.java:21
↓ 30 callers
Method
post
Posts an event to all registered subscribers. This method will return successfully after the event has been posted to all subscribers, and regardless
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:343
↓ 11 callers
Method
getEvents
()
rxbus/src/test/java/com/hwangjr/rxbus/StringCatcher.java:28
↓ 9 callers
Method
equals
(Object obj)
rxbus/src/main/java/com/hwangjr/rxbus/entity/EventType.java:47
↓ 7 callers
Method
getSubscriber
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:38
↓ 7 callers
Method
produce
Invokes the wrapped producer method and produce a {@link Observable}.
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:80
↓ 7 callers
Method
subscribe
(Object o)
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedProducerFinderTest.java:28
↓ 5 callers
Method
getSubject
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:108
↓ 5 callers
Method
isValid
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:64
↓ 5 callers
Method
toString
()
app/src/main/java/com/hwangjr/rxbus/app/MouseMam.java:85
↓ 5 callers
Method
unregister
()
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:301
↓ 4 callers
Method
findAllProducers
(Object listener)
rxbus/src/main/java/com/hwangjr/rxbus/finder/Finder.java:15
↓ 4 callers
Method
findAllSubscribers
(Object listener)
rxbus/src/main/java/com/hwangjr/rxbus/finder/Finder.java:17
↓ 4 callers
Method
getEvents
()
rxbus/src/test/java/com/hwangjr/rxbus/UnregisteringStringCatcher.java:54
↓ 4 callers
Method
getSubscribersForEventType
Retrieves a mutable set of the currently registered subscribers for {@code type}. If no subscribers are currently registered for {@code type}, this m
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:414
↓ 4 callers
Method
handle
(Object event)
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:104
↓ 3 callers
Method
assertContains
(T element, Collection<T> collection)
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:419
↓ 3 callers
Method
enforce
Enforce a valid thread for the given {@code bus}. Implementations may throw any runtime exception. @param bus Event bus instance on which an action i
rxbus/src/main/java/com/hwangjr/rxbus/thread/ThreadEnforcer.java:17
↓ 3 callers
Method
getRecordingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/EventProducerTest.java:120
↓ 3 callers
Method
getScheduler
(EventThread thread)
rxbus/src/main/java/com/hwangjr/rxbus/thread/EventThread.java:71
↓ 3 callers
Method
nextEvent
(int i)
rxbus/src/test/java/com/hwangjr/rxbus/EventBusInnerClassStressTest.java:83
↓ 3 callers
Method
onNext
(Object o)
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:364
↓ 3 callers
Method
throwRuntimeException
Throw a {@link RuntimeException} with given message and cause lifted from an {@link InvocationTargetException}. If the specified {@link InvocationTarg
rxbus/src/main/java/com/hwangjr/rxbus/entity/Event.java:11
↓ 3 callers
Method
unregister
Unregisters all producer and subscriber methods on a registered {@code object}. @param object object whose producer and subscriber methods should be
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:293
↓ 2 callers
Method
birth
Birth a cat to catch mouse. @return cat to catch mouse
app/src/main/java/com/hwangjr/rxbus/app/CatMam.java:23
↓ 2 callers
Method
dispatch
Dispatches {@code event} to the subscriber in {@code wrapper}. This method is an appropriate override point for subclasses that wish to make event de
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:390
↓ 2 callers
Method
dispatchProducerResult
(final SubscriberEvent subscriberEvent, ProducerEvent producer)
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:232
↓ 2 callers
Method
getEvents
()
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:435
↓ 2 callers
Method
getProducerForEventType
Retrieves the currently registered producer for {@code type}. If no producer is currently registered for {@code type}, this method will return {@code
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:403
↓ 2 callers
Method
getRecordingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:166
↓ 2 callers
Method
getTarget
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:142
↓ 2 callers
Method
handleEvent
Invokes the wrapped subscriber method to handle {@code event}. @param event event to handle @throws IllegalStateException if previously invalidat
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:120
↓ 2 callers
Method
hashCode
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/EventType.java:42
↓ 2 callers
Method
hashCode
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:141
↓ 2 callers
Method
hashCode
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:122
↓ 2 callers
Method
invalidate
If invalidated, will subsequently refuse to produce events. <p/> Should be called when the wrapped object is unregistered from the Bus.
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:73
↓ 2 callers
Method
loadAnnotatedMethods
Load all methods annotated with {@link Produce} or {@link Subscribe} into their respective caches for the specified class.
rxbus/src/main/java/com/hwangjr/rxbus/finder/AnnotatedFinder.java:53
↓ 2 callers
Method
subscribe
(@NonNull ObservableEmitter emitter)
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:82
↓ 2 callers
Method
toString
()
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:156
↓ 1 callers
Method
createSubscriber
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:34
↓ 1 callers
Method
equals
(Object obj)
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:127
↓ 1 callers
Method
flattenHierarchy
Flattens a class's type hierarchy into a set of Class objects. The set will include all superclasses (transitively), and all interfaces implemented b
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:425
↓ 1 callers
Method
getCats
Get all birth cats. @return cats
app/src/main/java/com/hwangjr/rxbus/app/CatMam.java:34
↓ 1 callers
Method
getClassesFor
(Class<?> concreteClass)
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:438
↓ 1 callers
Method
getErrorThrowingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/EventProducerTest.java:128
↓ 1 callers
Method
getErrorThrowingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:174
↓ 1 callers
Method
getExceptionThrowingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/EventProducerTest.java:124
↓ 1 callers
Method
getExceptionThrowingMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:170
↓ 1 callers
Method
getExecutor
()
rxbus/src/main/java/com/hwangjr/rxbus/thread/ThreadHandler.java:10
↓ 1 callers
Method
getHandler
()
rxbus/src/main/java/com/hwangjr/rxbus/thread/ThreadHandler.java:12
↓ 1 callers
Method
getPrintMethod
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:178
↓ 1 callers
Method
getRealClass
getRealClass, compat to kotlin base type @param cls @return
rxbus/src/main/java/com/hwangjr/rxbus/entity/EventType.java:71
↓ 1 callers
Method
hasRegistered
Whether all the subscriber methods on {@code object} to receive events and producer methods to provide events has registered. <p/> If any subscribers
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:251
↓ 1 callers
Method
initObservable
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:73
↓ 1 callers
Method
loadAnnotatedProducerMethods
(Class<?> listenerClass, Map<EventType, SourceMethod> pro
rxbus/src/main/java/com/hwangjr/rxbus/finder/AnnotatedFinder.java:37
↓ 1 callers
Method
loadAnnotatedSubscriberMethods
(Class<?> listenerClass, Map<EventType, Set<SourceMetho
rxbus/src/main/java/com/hwangjr/rxbus/finder/AnnotatedFinder.java:43
↓ 1 callers
Method
onCompleted
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:129
↓ 1 callers
Method
onNext
(Object o)
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:137
↓ 1 callers
Method
overriddenAndAnnotatedInSubclass
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:119
↓ 1 callers
Method
overriddenInSubclassNowhereAnnotated
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:124
↓ 1 callers
Method
produceEvent
Invokes the wrapped producer method. @throws IllegalStateException if previously invalidated. @throws InvocationTargetException if the wrapped me
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:101
↓ 1 callers
Method
squeak
()
app/src/main/java/com/hwangjr/rxbus/app/Mouse.java:7
↓ 1 callers
Method
toString
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:136
↓ 1 callers
Method
toString
()
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:117
Method
AnnotatedFinder
()
rxbus/src/main/java/com/hwangjr/rxbus/finder/AnnotatedFinder.java:194
Method
ApplicationTest
()
app/src/androidTest/java/com/hwangjr/rxbus/ApplicationTest.java:10
Method
Bus
Creates a new Bus named "default" that enforces actions on the main thread.
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:111
Method
BusProvider
()
app/src/main/java/com/hwangjr/rxbus/app/BusProvider.java:16
Method
DeadEvent
Creates a new DeadEvent. @param source object broadcasting the DeadEvent (generally the {@link Bus}). @param event the event that could not be deliv
rxbus/src/main/java/com/hwangjr/rxbus/entity/DeadEvent.java:22
Method
EventType
(String tag, Class<?> clazz)
rxbus/src/main/java/com/hwangjr/rxbus/entity/EventType.java:20
Method
ProducerEvent
(Object target, Method method, EventThread thread)
rxbus/src/main/java/com/hwangjr/rxbus/entity/ProducerEvent.java:45
Method
RxBusOlder
()
rxbus/src/main/java/com/hwangjr/rxbus/RxBusOlder.java:29
Method
SourceMethod
(EventThread thread, Method method)
rxbus/src/main/java/com/hwangjr/rxbus/finder/AnnotatedFinder.java:202
Method
SubscriberEvent
(Object target, Method method, EventThread thread)
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:50
Method
UnregisteringStringCatcher
(Bus bus)
rxbus/src/test/java/com/hwangjr/rxbus/UnregisteringStringCatcher.java:17
Method
accept
(Object event)
rxbus/src/main/java/com/hwangjr/rxbus/Bus.java:234
Method
accept
(Object event)
rxbus/src/main/java/com/hwangjr/rxbus/entity/SubscriberEvent.java:78
Method
addition_isCorrect
()
app/src/test/java/com/hwangjr/rxbus/ExampleUnitTest.java:11
Method
addition_isCorrect
()
rxbus/src/test/java/com/hwangjr/rxbus/ExampleUnitTest.java:11
Method
backPressure
()
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:122
Method
basicCatcherDistribution
()
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:60
Method
basicMethodCall
Checks that a no-frills, no-issues method call is properly executed. @throws Exception if the aforementioned proper execution is not to be had.
rxbus/src/test/java/com/hwangjr/rxbus/EventProducerTest.java:36
Method
basicMethodCall
Checks that a no-frills, no-issues method call is properly executed. @throws Exception if the aforementioned proper execution is not to be had.
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:41
Method
birth
birth a mouse, maybe white/black/dead mouse. @return
app/src/main/java/com/hwangjr/rxbus/app/MouseMam.java:33
Method
call
(Throwable throwable)
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:389
Method
call
(Object methodResult)
rxbus/src/test/java/com/hwangjr/rxbus/EventProducerTest.java:41
Method
call
(Object o)
rxbus/src/test/java/com/hwangjr/rxbus/entity/EventSubscriberTest.java:87
Method
caught
(Mouse mouse)
app/src/main/java/com/hwangjr/rxbus/app/Cat.java:7
Method
caught
Could not subscribe this method, not support {@link Mouse} interface. @param mouse
app/src/main/java/com/hwangjr/rxbus/app/CatMam.java:74
Method
compare
(SubscriberEvent eventSubscriber, SubscriberEvent eventSubscriber1)
rxbus/src/test/java/com/hwangjr/rxbus/UnregisteringSubscriberTest.java:108
Method
createSubscriber
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:87
Method
createSubscriber
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:129
Method
createSubscriber
()
rxbus/src/test/java/com/hwangjr/rxbus/AnnotatedSubscriberFinderTest.java:185
Method
deadEventForwarding
()
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:128
Method
deadEventPosting
()
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:142
Method
eat
(Object food)
rxbus/src/test/java/com/hwangjr/rxbus/BusTest.java:92
Method
enforce
(Bus bus)
rxbus/src/test/java/com/hwangjr/rxbus/ThreadEnforcerTest.java:15
Method
enforcerCalledForPost
()
rxbus/src/test/java/com/hwangjr/rxbus/ThreadEnforcerTest.java:29
Method
enforcerCalledForUnregister
()
rxbus/src/test/java/com/hwangjr/rxbus/ThreadEnforcerTest.java:38
next →
1–100 of 224, ranked by callers