Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add javadoc on ActionDisposable, correction of dangling javadoc comme… #6728

Closed
wants to merge 1 commit into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions src/main/java/io/reactivex/rxjava3/core/Flowable.java
Original file line number Diff line number Diff line change
Expand Up @@ -8134,7 +8134,6 @@ public final Single<Boolean> contains(final Object item) {
* @return a Single that emits a single item: the number of items emitted by the source Publisher as a
* 64-bit Long item
* @see <a href="http://reactivex.io/documentation/operators/count.html">ReactiveX operators documentation: Count</a>
* @see #count()
*/
@CheckReturnValue
@BackpressureSupport(BackpressureKind.UNBOUNDED_IN)
Expand Down Expand Up @@ -15102,7 +15101,6 @@ public final Completable switchMapCompletable(@NonNull Function<? super T, ? ext
* {@link CompletableSource} to be subscribed to and awaited for
* (non blockingly) for its terminal event
* @return the new Completable instance
* @see #switchMapCompletableDelayError(Function)
* @since 2.2
*/
@CheckReturnValue
Expand Down Expand Up @@ -15229,7 +15227,6 @@ <R> Flowable<R> switchMap0(Function<? super T, ? extends Publisher<? extends R>>
* return a {@code MaybeSource} to replace the current active inner source
* and get subscribed to.
* @return the new Flowable instance
* @see #switchMapMaybe(Function)
* @since 2.2
*/
@CheckReturnValue
Expand Down Expand Up @@ -15301,7 +15298,6 @@ public final <R> Flowable<R> switchMapMaybeDelayError(@NonNull Function<? super
* return a {@code SingleSource} to replace the current active inner source
* and get subscribed to.
* @return the new Flowable instance
* @see #switchMapSingle(Function)
* @since 2.2
*/
@CheckReturnValue
Expand Down
2 changes: 0 additions & 2 deletions src/main/java/io/reactivex/rxjava3/core/Maybe.java
Original file line number Diff line number Diff line change
Expand Up @@ -2537,7 +2537,6 @@ public final Single<Boolean> contains(final Object item) {
* @return a Single that emits a single item: the number of items emitted by the source Maybe as a
* 64-bit Long item
* @see <a href="http://reactivex.io/documentation/operators/count.html">ReactiveX operators documentation: Count</a>
* @see #count()
*/
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
Expand Down Expand Up @@ -2940,7 +2939,6 @@ public final Maybe<T> doOnSubscribe(Consumer<? super Disposable> onSubscribe) {
* @param onTerminate the action to invoke when the consumer calls {@code onComplete} or {@code onError}
* @return the new Maybe instance
* @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>
* @see #doOnTerminate(Action)
* @since 3.0.0
*/
@CheckReturnValue
Expand Down
3 changes: 0 additions & 3 deletions src/main/java/io/reactivex/rxjava3/core/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -7191,7 +7191,6 @@ public final Single<Boolean> contains(final Object element) {
* @return a Single that emits a single item: the number of items emitted by the source ObservableSource as a
* 64-bit Long item
* @see <a href="http://reactivex.io/documentation/operators/count.html">ReactiveX operators documentation: Count</a>
* @see #count()
*/
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
Expand Down Expand Up @@ -12476,7 +12475,6 @@ public final Completable switchMapCompletable(@NonNull Function<? super T, ? ext
* {@link CompletableSource} to be subscribed to and awaited for
* (non blockingly) for its terminal event
* @return the new Completable instance
* @see #switchMapCompletableDelayError(Function)
* @since 2.2
*/
@CheckReturnValue
Expand Down Expand Up @@ -12512,7 +12510,6 @@ public final Completable switchMapCompletableDelayError(@NonNull Function<? supe
* return a {@code MaybeSource} to replace the current active inner source
* and get subscribed to.
* @return the new Observable instance
* @see #switchMapMaybe(Function)
* @since 2.2
*/
@CheckReturnValue
Expand Down
1 change: 0 additions & 1 deletion src/main/java/io/reactivex/rxjava3/core/Single.java
Original file line number Diff line number Diff line change
Expand Up @@ -2568,7 +2568,6 @@ public final Single<T> doOnSubscribe(final Consumer<? super Disposable> onSubscr
* @param onTerminate the action to invoke when the consumer calls {@code onSuccess} or {@code onError}
* @return the new Single instance
* @see <a href="http://reactivex.io/documentation/operators/do.html">ReactiveX operators documentation: Do</a>
* @see #doOnTerminate(Action)
* @since 3.0.0
*/
@CheckReturnValue
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,9 @@
import io.reactivex.rxjava3.functions.Action;
import io.reactivex.rxjava3.internal.util.ExceptionHelper;

/**
* A Disposable container that manages an Action instance.
*/
final class ActionDisposable extends ReferenceDisposable<Action> {

private static final long serialVersionUID = -8219729196779211169L;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,10 +42,8 @@ public BlockingFlowableMostRecent(Flowable<T> source, T initialValue) {
public Iterator<T> iterator() {
MostRecentSubscriber<T> mostRecentSubscriber = new MostRecentSubscriber<T>(initialValue);

/**
* Subscribe instead of unsafeSubscribe since this is the final subscribe in the chain
* since it is for BlockingObservable.
*/
// Subscribe instead of unsafeSubscribe since this is the final subscribe in the chain
// since it is for BlockingObservable.
source.subscribe(mostRecentSubscriber);

return mostRecentSubscriber.getIterable();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,10 +42,8 @@ public BlockingObservableMostRecent(ObservableSource<T> source, T initialValue)
public Iterator<T> iterator() {
MostRecentObserver<T> mostRecentObserver = new MostRecentObserver<T>(initialValue);

/**
* Subscribe instead of unsafeSubscribe since this is the final subscribe in the chain
* since it is for BlockingObservable.
*/
// Subscribe instead of unsafeSubscribe since this is the final subscribe in the chain
// since it is for BlockingObservable.
source.subscribe(mostRecentObserver);

return mostRecentObserver.getIterable();
Expand Down