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
Method
exampleUsing
()
tests/java/itrx/chapter3/error/UsingExample.java:36
Method
exampleWithAccumulator
()
tests/java/itrx/chapter2/aggregation/ReduceExample.java:71
Method
exampleWithSignal
()
tests/java/itrx/chapter3/timeshifted/BufferExample.java:77
Method
exampleWithSize
()
tests/java/itrx/chapter1/ReplaySubjectExample.java:53
Method
exampleWithTime
()
tests/java/itrx/chapter1/ReplaySubjectExample.java:66
Method
exampleZipMultiple
()
tests/java/itrx/chapter3/combining/ZipExample.java:71
Method
exampleZipUneven
()
tests/java/itrx/chapter3/combining/ZipExample.java:88
Method
exampleZipWith
()
tests/java/itrx/chapter3/combining/ZipExample.java:100
Method
exampleZipWithIterable
()
tests/java/itrx/chapter3/combining/ZipExample.java:116
Method
onCompleted
()
tests/java/itrx/chapter2/transforming/FlatMapExample.java:45
Method
onCompleted
()
tests/java/itrx/chapter2/transforming/TimestampTimeIntervalExample.java:46
Method
onCompleted
()
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:42
Method
onCompleted
()
tests/java/itrx/chapter2/transforming/MaterializeExample.java:41
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/ToMapExample.java:46
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/CountExample.java:40
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/SingleExample.java:46
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/FirstExample.java:43
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/ReduceExample.java:40
Method
onCompleted
()
tests/java/itrx/chapter2/aggregation/LastExample.java:40
Method
onCompleted
()
tests/java/itrx/chapter3/combining/RepeatExample.java:43
Method
onError
(Throwable e)
tests/java/itrx/chapter2/transforming/FlatMapExample.java:49
Method
onError
(Throwable e)
tests/java/itrx/chapter2/transforming/TimestampTimeIntervalExample.java:50
Method
onError
(Throwable e)
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:46
Method
onError
(Throwable e)
tests/java/itrx/chapter2/transforming/MaterializeExample.java:45
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/ScanExample.java:46
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/ToMapExample.java:50
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/CountExample.java:44
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/SingleExample.java:50
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/FirstExample.java:47
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/ReduceExample.java:44
Method
onError
(Throwable e)
tests/java/itrx/chapter2/aggregation/LastExample.java:44
Method
onError
(Throwable e)
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:71
Method
onError
(Throwable e)
tests/java/itrx/chapter3/combining/RepeatExample.java:47
Method
onError
(Throwable e)
tests/java/itrx/chapter3/sideeffects/DoOnExample.java:49
Method
onError
(Throwable e)
tests/java/itrx/chapter3/custom/SerializeExample.java:74
Method
onError
(Throwable e)
tests/java/itrx/chapter3/custom/LiftExample.java:53
Method
onNext
(Object v)
tests/java/itrx/chapter2/transforming/FlatMapExample.java:53
Method
onNext
(Object v)
tests/java/itrx/chapter2/transforming/TimestampTimeIntervalExample.java:54
Method
onNext
(Object v)
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:50
Method
onNext
(Object v)
tests/java/itrx/chapter2/transforming/MaterializeExample.java:49
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/ToMapExample.java:54
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/CountExample.java:48
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/SingleExample.java:54
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/FirstExample.java:51
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/ReduceExample.java:48
Method
onNext
(Object v)
tests/java/itrx/chapter2/aggregation/LastExample.java:48
Method
onNext
(T t)
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:76
Method
onNext
(Object v)
tests/java/itrx/chapter3/combining/RepeatExample.java:51
Method
onStart
()
tests/java/itrx/chapter4/backpressure/ControlledPullSubscriber.java:61
Method
test
()
tests/java/itrx/chapter2/aggregation/CollectExample.java:48
Method
test
()
tests/java/itrx/chapter2/aggregation/CountExample.java:94
Method
test
()
tests/java/itrx/chapter2/aggregation/ReduceExample.java:87
Method
test
()
tests/java/itrx/chapter1/PublishSubjectExample.java:52
Method
test
()
tests/java/itrx/chapter4/scheduling/SingleThreadedExample.java:63
Method
test
()
tests/java/itrx/chapter4/testing/TestSubscriberExample.java:39
Method
test
()
tests/java/itrx/chapter3/combining/CombineLatestExample.java:68
Method
test
()
tests/java/itrx/chapter3/combining/SwitchOnNextExample.java:66
Method
test
()
tests/java/itrx/chapter3/combining/StartWithExample.java:52
Method
test
()
tests/java/itrx/chapter3/combining/SwitchMapExample.java:61
Method
test
()
tests/java/itrx/chapter3/sideeffects/MutablePipelineExample.java:61
Method
test
()
tests/java/itrx/chapter3/error/RetryWhenExample.java:65
Method
test1Error
()
tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java:99
Method
test2Errors
()
tests/java/itrx/chapter3/combining/MergeDelayErrorExample.java:120
Method
testAdvanceTo
()
tests/java/itrx/chapter4/testing/TestSchedulerExample.java:150
Method
testAll
()
tests/java/itrx/chapter2/inspection/AllExample.java:135
Method
testAllEarlyFalse
()
tests/java/itrx/chapter2/inspection/AllExample.java:157
Method
testAllError
()
tests/java/itrx/chapter2/inspection/AllExample.java:190
Method
testAllErrorAfterComplete
()
tests/java/itrx/chapter2/inspection/AllExample.java:209
Method
testAmb
()
tests/java/itrx/chapter3/combining/AmbExample.java:60
Method
testAmbWith
()
tests/java/itrx/chapter3/combining/AmbExample.java:76
Method
testBadIndex
()
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:128
Method
testBadIndexFail
()
tests/java/itrx/chapter3/sideeffects/SideEffectExample.java:149
Method
testBlocking
()
tests/java/itrx/chapter4/scheduling/SubscribeOnExample.java:105
Method
testBlockingForEach
()
tests/java/itrx/chapter3/leaving/ForEachExample.java:118
Method
testBlockingForEachError
()
tests/java/itrx/chapter3/leaving/ForEachExample.java:147
Method
testBuffer
()
tests/java/itrx/chapter4/backpressure/ConsumerSideExample.java:103
Method
testByCount
()
tests/java/itrx/chapter4/coincidence/WindowExample.java:122
Method
testByCount
()
tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java:69
Method
testByCount
()
tests/java/itrx/chapter3/timeshifted/BufferExample.java:131
Method
testByCountAndTime
()
tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java:102
Method
testByCountAndTime
()
tests/java/itrx/chapter3/timeshifted/BufferExample.java:170
Method
testBySignal
()
tests/java/itrx/chapter4/coincidence/WindowExample.java:162
Method
testByTime
()
tests/java/itrx/chapter4/coincidence/WindowExample.java:140
Method
testByTime
()
tests/java/itrx/chapter3/timeshifted/TakeLastBufferExample.java:84
Method
testByTime
()
tests/java/itrx/chapter3/timeshifted/BufferExample.java:148
Method
testCache
()
tests/java/itrx/chapter3/hotandcold/CacheExample.java:86
Method
testCacheUnsubscribe
()
tests/java/itrx/chapter3/hotandcold/CacheExample.java:117
Method
testCancelWithInterrupt
()
tests/java/itrx/chapter4/scheduling/SchedulerExample.java:154
Method
testCancelWork
()
tests/java/itrx/chapter4/scheduling/SchedulerExample.java:133
Method
testCast
()
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:102
Method
testCastFail
()
tests/java/itrx/chapter2/transforming/CastTypeOfExample.java:117
Method
testCollision
()
tests/java/itrx/chapter4/testing/TestSchedulerExample.java:229
Method
testCompleted
()
tests/java/itrx/chapter1/BehaviorSubjectExample.java:87
Method
testComposeFromClass
()
tests/java/itrx/chapter3/custom/ComposeExample.java:99
Method
testComposeParameterised
()
tests/java/itrx/chapter3/custom/ComposeExample.java:112
Method
testConcat
()
tests/java/itrx/chapter3/combining/ConcatExample.java:93
Method
testConcatDynamic
()
tests/java/itrx/chapter3/combining/ConcatExample.java:108
Method
testConcatMap
()
tests/java/itrx/chapter2/transforming/ConcatMapExample.java:62
Method
testConcatWith
()
tests/java/itrx/chapter3/combining/ConcatExample.java:135
Method
testConnect
()
tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java:151
← previous
next →
301–400 of 569, ranked by callers