Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/airbnb/RxGroups
/ functions
Functions
267 in github.com/airbnb/RxGroups
⨍
Functions
267
◇
Types & classes
56
↓ 62 callers
Method
subscribe
(@NonNull ObservableEmitter<Integer> emitter)
rxgroups/src/test/java/com/airbnb/rxgroups/SubscriptionProxyTest.java:37
↓ 55 callers
Method
create
(Observable<T> observable, Action onTerminate)
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:50
↓ 55 callers
Method
newGroup
@return a new {@link ObservableGroup} with a unique groupId
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableManager.java:58
↓ 41 callers
Method
transform
Transforms an existing {@link Observable} by returning a new {@link Observable} that is automatically added to this {@link ObservableGroup} with the p
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:146
↓ 37 callers
Method
hasObservables
Returns whether the observer has any existing {@link Observable}.
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:369
↓ 31 callers
Method
onNext
(@NonNull T t)
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:96
↓ 27 callers
Method
onComplete
()
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:108
↓ 13 callers
Method
dispose
Disposes all Observables managed by this group. Also clears any references to existing {@link Observer} objects in order to avoid leaks. This does not
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:229
↓ 13 callers
Method
isCancelled
Indicates whether this {@code SourceSubscription} is currently cancelled, that is, whether the underlying HTTP request associated to it has been cance
rxgroups/src/main/java/com/airbnb/rxgroups/SourceSubscription.java:28
↓ 12 callers
Method
id
()
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:51
↓ 11 callers
Method
subscription
@return a {@link SourceSubscription} with which the {@link Observer} can dispose from or cancel before the {@link Observable} has completed. If no {@l
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:271
↓ 10 callers
Method
format
(String template, @Nullable Object... args)
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:407
↓ 10 callers
Method
getObserverTag
(Observer<?> observer)
rxgroups/src/main/java/com/airbnb/rxgroups/Utils.java:7
↓ 9 callers
Method
dispose
()
rxgroups/src/test/java/com/airbnb/rxgroups/SubscriptionProxyTest.java:116
↓ 9 callers
Method
getGroup
@return an existing group provided groupId. Throws {@link IllegalStateException} if no group with the provided groupId exists or it is already destroy
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableManager.java:43
↓ 9 callers
Method
getObservablesForObserver
( Observer<?> observer)
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:127
↓ 9 callers
Method
logError
(String msg, Object... args)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:268
↓ 9 callers
Method
observable
Returns an existing {@link Observable} for the {@link TaggedObserver}. <p> <p> Does not change the locked status of this {@link ObservableGroup}. If i
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:246
↓ 9 callers
Method
onCreate
Call this method from your Activity or Fragment's onCreate method
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:57
↓ 8 callers
Method
destroy
Clears the provided group. References will be released, and no future results will be returned. Once a group is destroyed it is an error to use it aga
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableManager.java:73
↓ 8 callers
Method
group
@return the {@link ObservableGroup} associated to this instance
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:91
↓ 8 callers
Method
isDisposed
()
rxgroups/src/test/java/com/airbnb/rxgroups/SubscriptionProxyTest.java:120
↓ 8 callers
Method
lock
Locks (prevents) Observables added to this group from emitting new events. Observables added via {@link #transform(Observer, String)} while the group
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:199
↓ 6 callers
Method
cancel
Stops the receipt of notifications on the {@link io.reactivex.Observer} that was registered when this Subscription was received. This allows unregiste
rxgroups/src/main/java/com/airbnb/rxgroups/SourceSubscription.java:36
↓ 6 callers
Method
hasObservables
Call {@link ObservableGroup#hasObservables(Observer)} for the group managed by this instance.
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:116
↓ 6 callers
Method
toString
()
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:384
↓ 6 callers
Method
unlock
Unlocks (releases) Observables added to this group to emit new events until they are locked, unsubscribed or cancelled.
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:213
↓ 5 callers
Method
isDisposed
()
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:82
↓ 5 callers
Method
resubscribeAll
(TaggedObserver<? super T> observer)
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:290
↓ 4 callers
Method
add
Adds an {@link Observable} and {@link Observer} to this group and subscribes to it. If an {@link Observable} with the same tag is already added, the p
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:99
↓ 4 callers
Method
checkNotNull
Ensures that an object reference passed as a parameter to the calling method is not null. @param reference an object reference @return the non-null r
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:208
↓ 4 callers
Method
destroy
Cancels all subscriptions and releases references to Observables and Observers. No more Observables can be added to this group after it has been destr
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:167
↓ 4 callers
Method
isNonResubscribableTag
(String tag)
rxgroups/src/main/java/com/airbnb/rxgroups/NonResubscribableTag.java:19
↓ 4 callers
Method
subscribe
(@NonNull final ObservableEmitter<T> emitter)
rxgroups/src/main/java/com/airbnb/rxgroups/GroupSubscriptionTransformer.java:45
↓ 3 callers
Method
badPositionIndex
(int index, int size, String desc)
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:356
↓ 3 callers
Method
cancelAllObservablesForObserver
Removes all {@link Observable} for the given {@link Observer} and cancels their subscriptions. No more events will be delivered to its subscriber.
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:333
↓ 3 callers
Method
create
(Object object)
rxgroups/src/main/java/com/airbnb/rxgroups/NonResubscribableTag.java:15
↓ 3 callers
Method
dispose
()
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:76
↓ 3 callers
Method
forAllObservables
(Consumer<ManagedObservable<?>> action)
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:179
↓ 3 callers
Method
initializeAutoTaggingAndResubscription
Calls {@link ObservableGroup#initializeAutoTaggingAndResubscription(Object)} (Object, Class)} for the group managed by this instance.
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:133
↓ 3 callers
Method
initializeAutoTaggingAndResubscriptionInTargetClassOnly
(Object target, Class<?> targetClass, ObservableGroup group)
rxgroups/src/main/java/com/airbnb/rxgroups/ResubscribeHelper.java:31
↓ 3 callers
Method
onDestroy
(boolean isFinishing)
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:164
↓ 3 callers
Method
setTag
(String tag)
rxgroups/src/main/java/com/airbnb/rxgroups/AutoTaggableObserver.java:12
↓ 2 callers
Method
checkNotDestroyed
()
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:380
↓ 2 callers
Method
checkState
Ensures the truth of an expression involving the state of the calling instance, but not involving any parameters to the calling method. @param expres
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:155
↓ 2 callers
Method
disposableWrapper
(final ObservableEmitter<? super T> emitter)
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:94
↓ 2 callers
Method
dispose
()
rxgroups/src/main/java/com/airbnb/rxgroups/ManagedObservable.java:56
↓ 2 callers
Method
initializeAutoTaggingAndResubscription
Initializes all helper classes in {@code target} class hierarchy.
rxgroups/src/main/java/com/airbnb/rxgroups/ResubscribeHelper.java:19
↓ 2 callers
Method
isAutoTaggable
(Element observerFieldElement, Types typeUtil, Elements elementUtil)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ProcessorUtils.java:31
↓ 2 callers
Method
isResubscribingObserver
(Element observerFieldElement, Types typeUtil, Elements elementUtil)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ProcessorUtils.java:15
↓ 2 callers
Method
onError
(@NonNull Throwable e)
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:102
↓ 2 callers
Method
onSaveInstanceState
Call this method from your Activity or Fragment's onSaveInstanceState method
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:214
↓ 2 callers
Method
processObserver
(Element observer, LinkedHashMap<TypeElement, ClassToGenerateInfo> info, Class<? extends Annotation>
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:113
↓ 2 callers
Method
resubscribe
Resubscribes the {@link TaggedObserver} to the observable identified by {@code observableTag}.
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:300
↓ 2 callers
Method
run
()
rxgroups/src/test/java/com/airbnb/rxgroups/SubscriptionProxyTest.java:105
↓ 2 callers
Method
transform
Calls {@link ObservableGroup#transform(Observer)} for the group managed by this instance.
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:99
↓ 1 callers
Method
accept
(ManagedObservable<?> managedObservable)
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:202
↓ 1 callers
Method
addObserver
(String observerName, ObserverInfo type)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:311
↓ 1 callers
Method
badElementIndex
(int index, int size, String desc)
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:313
↓ 1 callers
Method
badPositionIndexes
(int start, int end, int size)
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:385
↓ 1 callers
Method
cancelAndRemove
Removes the {@link Observable} identified by {@code observableTag} for the given {@link Observer} and cancels it subscription. No more events will be
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:324
↓ 1 callers
Method
dispose
()
rxgroups/src/main/java/com/airbnb/rxgroups/TestAutoResubscribingObserver.java:37
↓ 1 callers
Method
findConstructorForClass
(Class<?> cls)
rxgroups/src/main/java/com/airbnb/rxgroups/ResubscribeHelper.java:61
↓ 1 callers
Method
generateClass
(ClassToGenerateInfo info)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:223
↓ 1 callers
Method
generateConstructor
(ClassToGenerateInfo info)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:236
↓ 1 callers
Method
getCustomTag
(Element observer, Class<? extends Annotation> annotationClass)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:132
↓ 1 callers
Method
getGeneratedClassName
(TypeElement classElement)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:213
↓ 1 callers
Method
getOrCreateTargetClass
( Map<TypeElement, ClassToGenerateInfo> modelClassMap, TypeElement classElement)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:199
↓ 1 callers
Method
getTag
@return A string which uniquely identifies this Observer. In order to use {@link ObservableGroup#resubscribe(TaggedObserver, String)} the tag must be
rxgroups/src/main/java/com/airbnb/rxgroups/TaggedObserver.java:17
↓ 1 callers
Method
id
()
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableManager.java:65
↓ 1 callers
Method
invokeConstructor
(Constructor<?> constructor, Object target, ObservableGroup group)
rxgroups/src/main/java/com/airbnb/rxgroups/ResubscribeHelper.java:41
↓ 1 callers
Method
isDestroyed
Returns whether this group has been already destroyed or not.
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:376
↓ 1 callers
Method
isDisposed
()
rxgroups/src/main/java/com/airbnb/rxgroups/ManagedObservable.java:61
↓ 1 callers
Method
isTaggedObserver
(Element observerFieldElement, Types typeUtil, Elements elementUtil)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ProcessorUtils.java:23
↓ 1 callers
Method
lock
()
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:205
↓ 1 callers
Method
observableManager
()
sample/src/main/java/com/airbnb/rxgroups/SampleApplication.java:32
↓ 1 callers
Method
onClickLockUnlockGroup
(View view)
sample/src/main/java/com/airbnb/rxgroups/MainActivity.java:102
↓ 1 callers
Method
onClickStartStopTimer
(View view)
sample/src/main/java/com/airbnb/rxgroups/MainActivity.java:117
↓ 1 callers
Method
proxiedObservable
()
rxgroups/src/main/java/com/airbnb/rxgroups/ManagedObservable.java:73
↓ 1 callers
Method
removeNonResubscribableObservers
()
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:390
↓ 1 callers
Method
timerObservable
()
sample/src/main/java/com/airbnb/rxgroups/SampleApplication.java:36
↓ 1 callers
Method
unlock
()
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:209
↓ 1 callers
Method
unlock
()
rxgroups/src/main/java/com/airbnb/rxgroups/ManagedObservable.java:65
↓ 1 callers
Method
validateObserverField
(Element observerFieldElement, Class<? extends Annotation> annotationClas
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:143
Method
BaseClass_ObservableResubscriber
(BaseClass target, ObservableGroup group)
rxgroups/src/test/java/com/airbnb/rxgroups/ResubscribeHelperTest.java:46
Method
ClassToGenerateInfo
(TypeElement originalClassName, ClassName generatedClassName)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:306
Method
GroupLifecycleManager
(ObservableManager observableManager, ObservableGroup group)
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:51
Method
GroupResubscriptionTransformer
(ManagedObservable<T> managedObservable)
rxgroups/src/main/java/com/airbnb/rxgroups/GroupResubscriptionTransformer.java:30
Method
GroupSubscriptionTransformer
(ObservableGroup group, String observerTag, String observableTag)
rxgroups/src/main/java/com/airbnb/rxgroups/GroupSubscriptionTransformer.java:37
Method
LeafClass_ObservableResubscriber
(LeafClass target, ObservableGroup group)
rxgroups/src/test/java/com/airbnb/rxgroups/ResubscribeHelperTest.java:64
Method
ManagedObservable
(String observerTag, String observableTag, Observable<T> upstreamObservable, ObservableEmitter<? super T
rxgroups/src/main/java/com/airbnb/rxgroups/ManagedObservable.java:34
Method
MiddleClass_ObservableResubscriber
(MiddleClass target, ObservableGroup group)
rxgroups/src/test/java/com/airbnb/rxgroups/ResubscribeHelperTest.java:55
Method
ObservableGroup
(long groupId)
rxgroups/src/main/java/com/airbnb/rxgroups/ObservableGroup.java:47
Method
ObserverInfo
(ObserverType type, String customTag, boolean autoTaggable, boolean shouldAutoResubscribe)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:283
Method
Preconditions
()
rxgroups/src/main/java/com/airbnb/rxgroups/Preconditions.java:95
Method
RxGroupsResubscriptionProcessorException
(String message)
rxgroups-processor/src/main/java/com/airbnb/rxgroups/processor/ResubscriptionProcessor.java:263
Method
State
(UUID managerId, long groupId)
rxgroups-android/src/main/java/com/airbnb/rxgroups/GroupLifecycleManager.java:223
Method
SubscriptionProxy
(Observable<T> sourceObservable, Action onTerminate)
rxgroups/src/main/java/com/airbnb/rxgroups/SubscriptionProxy.java:43
Method
TestAutoResubscribingObserver
(String tag)
rxgroups/src/main/java/com/airbnb/rxgroups/TestAutoResubscribingObserver.java:13
Method
addition_isCorrect
()
sample/src/test/java/com/airbnb/rxgroups/ExampleUnitTest.java:11
next →
1–100 of 267, ranked by callers