Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Froussios/Intro-To-RxJava
/ functions
Functions
569 in github.com/Froussios/Intro-To-RxJava
⨍
Functions
569
◇
Types & classes
122
↓ 113 callers
Method
range
(int start, int count)
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:74
↓ 97 callers
Method
onNext
(T t)
tests/java/itrx/chapter3/custom/LiftExample.java:59
↓ 78 callers
Method
create
(Func1<T,R> transformer)
tests/java/itrx/chapter3/custom/LiftExample.java:68
↓ 62 callers
Method
onNext
(Object v)
tests/java/itrx/chapter2/transforming/MapExample.java:48
↓ 34 callers
Method
create
(T1 item1, T2 item2)
tests/java/itrx/chapter4/coincidence/JoinExample.java:46
↓ 30 callers
Method
onNext
(Object v)
tests/java/itrx/chapter3/error/ResumeExample.java:51
↓ 30 callers
Method
test
()
tests/java/itrx/chapter3/combining/ZipExample.java:135
↓ 20 callers
Method
onNext
(Object v)
tests/java/itrx/chapter3/sideeffects/DoOnExample.java:53
↓ 18 callers
Method
onNext
(Long t)
tests/java/itrx/chapter4/backpressure/ConsumerSideExample.java:85
↓ 18 callers
Method
onNext
(Integer t)
tests/java/itrx/chapter3/custom/SerializeExample.java:79
↓ 14 callers
Method
onError
(Throwable e)
tests/java/itrx/chapter3/error/ResumeExample.java:47
↓ 12 callers
Method
onCompleted
()
tests/java/itrx/chapter2/transforming/MapExample.java:40
↓ 12 callers
Method
onCompleted
()
tests/java/itrx/chapter3/custom/SerializeExample.java:69
↓ 12 callers
Method
test
()
tests/java/itrx/chapter2/aggregation/NestExample.java:49
↓ 11 callers
Method
onCompleted
()
tests/java/itrx/chapter3/custom/LiftExample.java:47
↓ 10 callers
Method
onCompleted
()
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:66
↓ 10 callers
Method
requestMore
(int n)
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:81
↓ 10 callers
Method
test
()
tests/java/itrx/chapter3/hotandcold/ColdExample.java:64
↓ 9 callers
Method
create
(T1 item1, T2 item2)
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:46
↓ 8 callers
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/ScanExample.java:50
↓ 8 callers
Method
test
()
tests/java/itrx/chapter4/testing/ExampleExample.java:39
↓ 6 callers
Method
call
(Subscriber<? super R> subscriber)
tests/java/itrx/chapter3/custom/LiftExample.java:43
↓ 6 callers
Method
onError
(Throwable e)
tests/java/itrx/chapter2/transforming/MapExample.java:44
↓ 6 callers
Method
test
()
tests/java/itrx/chapter2/reducing/FilterExample.java:58
↓ 5 callers
Method
getCount
()
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:39
↓ 5 callers
Method
next
()
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:53
↓ 5 callers
Method
printThread
(String message)
tests/java/itrx/chapter4/scheduling/SchedulersExample.java:39
↓ 5 callers
Method
test
()
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:98
↓ 5 callers
Method
test
()
tests/java/itrx/chapter4/backpressure/ReactivePullExample.java:63
↓ 4 callers
Method
getValuesUnsafe
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:51
↓ 4 callers
Method
getValuesUnsafe2
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:55
↓ 4 callers
Method
inc
()
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:36
↓ 4 callers
Method
onNext
(Long t)
tests/java/itrx/chapter4/backpressure/NoBackpressureExample.java:112
↓ 3 callers
Method
getValues
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:69
↓ 3 callers
Method
hasNext
()
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:48
↓ 3 callers
Method
iterator
()
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:68
↓ 3 callers
Method
play
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:59
↓ 2 callers
Method
equals
(Object obj)
tests/java/itrx/chapter2/aggregation/ToMapExample.java:68
↓ 2 callers
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/ScanExample.java:42
↓ 2 callers
Method
onCompleted
()
tests/java/itrx/chapter3/sideeffects/DoOnExample.java:45
↓ 2 callers
Method
onCompleted
()
tests/java/itrx/chapter3/error/ResumeExample.java:43
↓ 2 callers
Method
play
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:41
↓ 2 callers
Method
test
()
tests/java/itrx/chapter2/inspection/ContainsExample.java:60
↓ 2 callers
Method
test
()
tests/java/itrx/chapter4/scheduling/UnsubscribeOnExample.java:67
↓ 2 callers
Method
toString
()
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:60
↓ 1 callers
Method
equals
(Object obj)
tests/java/itrx/chapter4/coincidence/JoinExample.java:50
↓ 1 callers
Method
play
()
tests/java/itrx/chapter3/sideeffects/AsObservableExample.java:73
↓ 1 callers
Method
test
()
tests/java/itrx/chapter1/RxContractExample.java:67
↓ 1 callers
Method
test
()
tests/java/itrx/chapter3/combining/MergeExample.java:81
Method
AverageAcc
(int sum, int count)
tests/java/itrx/chapter3/custom/ComposeExample.java:44
Method
ControlledPullSubscriber
( Action1<T> onNextAction, Action1<Throwable> onErrorAction, Action0 onCompletedAction)
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:42
Method
Data
(int id, String name)
tests/java/itrx/chapter3/sideeffects/MutablePipelineExample.java:37
Method
Indexed
(int index, T item)
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:47
Method
MyMap
(Func1<T,R> transformer)
tests/java/itrx/chapter3/custom/LiftExample.java:39
Method
Person
(String name, int age)
tests/java/itrx/chapter2/aggregation/ToMapExample.java:63
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/transforming/MapExample.java:37
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/transforming/FlatMapExample.java:42
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/transforming/TimestampTimeIntervalExample.java:43
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:39
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/transforming/MaterializeExample.java:38
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/ScanExample.java:39
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/ToMapExample.java:43
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/CountExample.java:37
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/SingleExample.java:43
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/FirstExample.java:40
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/ReduceExample.java:37
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter2/aggregation/LastExample.java:37
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter3/combining/RepeatExample.java:40
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter3/sideeffects/DoOnExample.java:42
Method
PrintSubscriber
(String name)
tests/java/itrx/chapter3/error/ResumeExample.java:40
Method
Range
(int start, int count)
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:63
Method
RangeIterator
(int start, int count)
tests/java/itrx/chapter2/transforming/FlatMapIterableExample.java:43
Method
RunningAverage
()
tests/java/itrx/chapter3/custom/ComposeExample.java:52
Method
Tuple
(T1 item1, T2 item2)
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:41
Method
Tuple
(T1 item1, T2 item2)
tests/java/itrx/chapter4/coincidence/JoinExample.java:41
Method
call
(Observable<Integer> source)
tests/java/itrx/chapter3/custom/ComposeExample.java:60
Method
equals
(Object obj)
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:50
Method
equals
(Object obj)
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:52
Method
example
()
tests/java/itrx/chapter2/reducing/FilterExample.java:35
Method
example
()
tests/java/itrx/chapter2/aggregation/CollectExample.java:36
Method
example
()
tests/java/itrx/chapter2/aggregation/CountExample.java:55
Method
example
()
tests/java/itrx/chapter2/aggregation/NestExample.java:34
Method
example
()
tests/java/itrx/chapter2/aggregation/ReduceExample.java:55
Method
example
()
tests/java/itrx/chapter1/PublishSubjectExample.java:34
Method
example
()
tests/java/itrx/chapter1/RxContractExample.java:35
Method
example
()
tests/java/itrx/chapter4/scheduling/UnsubscribeOnExample.java:36
Method
example
()
tests/java/itrx/chapter4/scheduling/SingleThreadedExample.java:32
Method
example
()
tests/java/itrx/chapter4/coincidence/GroupJoinExample.java:66
Method
example
()
tests/java/itrx/chapter4/backpressure/ReactivePullExample.java:37
Method
example
()
tests/java/itrx/chapter3/combining/CombineLatestExample.java:37
Method
example
()
tests/java/itrx/chapter3/combining/SwitchOnNextExample.java:39
Method
example
()
tests/java/itrx/chapter3/combining/MergeExample.java:39
Method
example
()
tests/java/itrx/chapter3/combining/StartWithExample.java:34
Method
example
()
tests/java/itrx/chapter3/combining/ZipExample.java:37
Method
example
()
tests/java/itrx/chapter3/combining/SwitchMapExample.java:37
Method
example
()
tests/java/itrx/chapter3/sideeffects/MutablePipelineExample.java:43
Method
example
()
tests/java/itrx/chapter3/error/RetryWhenExample.java:37
Method
example
()
tests/java/itrx/chapter3/hotandcold/ColdExample.java:37
Method
example1Error
()
tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java:41
Method
example2Errors
()
tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java:64
next →
1–100 of 569, ranked by callers