Skip to content

Commit 45341ee

Browse files
committed
adding diagrams to javadocs for replay(selector) variants
1 parent 6069428 commit 45341ee

File tree

1 file changed

+20
-2
lines changed

1 file changed

+20
-2
lines changed

rxjava-core/src/main/java/rx/Observable.java

Lines changed: 20 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5870,6 +5870,8 @@ public final ConnectableObservable<T> replay() {
58705870
* Returns an observable sequence that is the result of invoking the
58715871
* selector on a connectable observable sequence that shares a single
58725872
* subscription to the underlying sequence and starts with initial value.
5873+
* <p>
5874+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.f.png">
58735875
*
58745876
* @param <R>
58755877
* the return element type
@@ -5897,6 +5899,8 @@ public final Subject<T, T> call() {
58975899
* Returns an observable sequence that is the result of invoking the
58985900
* selector on a connectable observable sequence that shares a single
58995901
* subscription to the underlying sequence replaying {@code bufferSize} notifications.
5902+
* <p>
5903+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fn.png">
59005904
*
59015905
* @param <R>
59025906
* the return element type
@@ -5924,7 +5928,10 @@ public final Subject<T, T> call() {
59245928
/**
59255929
* Returns an observable sequence that is the result of invoking the
59265930
* selector on a connectable observable sequence that shares a single
5927-
* subscription to the underlying sequence replaying {@code bufferSize} notifications within window.
5931+
* subscription to the underlying sequence replaying {@code bufferSize}
5932+
* notifications within window.
5933+
* <p>
5934+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fnt.png">
59285935
*
59295936
* @param <R>
59305937
* the return element type
@@ -5951,7 +5958,10 @@ public final <R> Observable<R> replay(Func1<? super Observable<T>, ? extends Obs
59515958
/**
59525959
* Returns an observable sequence that is the result of invoking the
59535960
* selector on a connectable observable sequence that shares a single
5954-
* subscription to the underlying sequence replaying {@code bufferSize} notifications within window.
5961+
* subscription to the underlying sequence replaying {@code bufferSize}
5962+
* notifications within window.
5963+
* <p>
5964+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fnts.png">
59555965
*
59565966
* @param <R>
59575967
* the return element type
@@ -5990,6 +6000,8 @@ public final Subject<T, T> call() {
59906000
* Returns an observable sequence that is the result of invoking the
59916001
* selector on a connectable observable sequence that shares a single
59926002
* subscription to the underlying sequence replaying {@code bufferSize} notifications.
6003+
* <p>
6004+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fns.png">
59936005
*
59946006
* @param <R>
59956007
* the return element type
@@ -6021,6 +6033,8 @@ public final Subject<T, T> call() {
60216033
* selector on a connectable observable sequence that shares a single
60226034
* subscription to the underlying sequence replaying all notifications
60236035
* within window.
6036+
* <p>
6037+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.ft.png">
60246038
*
60256039
* @param <R>
60266040
* the return element type
@@ -6048,6 +6062,8 @@ public final <R> Observable<R> replay(Func1<? super Observable<T>, ? extends Obs
60486062
* selector on a connectable observable sequence that shares a single
60496063
* subscription to the underlying sequence replaying all notifications
60506064
* within window.
6065+
* <p>
6066+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fts.png">
60516067
*
60526068
* @param <R>
60536069
* the return element type
@@ -6082,6 +6098,8 @@ public final Subject<T, T> call() {
60826098
* Returns an observable sequence that is the result of invoking the
60836099
* selector on a connectable observable sequence that shares a single
60846100
* subscription to the underlying sequence replaying all notifications.
6101+
* <p>
6102+
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/replay.fs.png">
60856103
*
60866104
* @param <R>
60876105
* the return element type

0 commit comments

Comments
 (0)