|
20 | 20 | import java.util.concurrent.*;
|
21 | 21 | import java.util.concurrent.atomic.AtomicBoolean;
|
22 | 22 |
|
23 |
| -import rx.annotations.*; |
24 | 23 | import rx.exceptions.*;
|
25 | 24 | import rx.functions.*;
|
26 | 25 | import rx.internal.observers.AssertableSubscriberObservable;
|
|
35 | 34 | * Represents a deferred computation without any value but only indication for completion or exception.
|
36 | 35 | *
|
37 | 36 | * The class follows a similar event pattern as Reactive-Streams: onSubscribe (onError|onComplete)?
|
38 |
| - * |
39 |
| - * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number) |
| 37 | + * |
| 38 | + * @since 1.3 |
40 | 39 | */
|
41 |
| -@Beta |
42 | 40 | public class Completable {
|
43 | 41 | /** The actual subscription action. */
|
44 | 42 | private final OnSubscribe onSubscribe;
|
@@ -539,9 +537,8 @@ public void call(rx.CompletableSubscriber s) {
|
539 | 537 | * Completable's protocol are held.
|
540 | 538 | * @param producer the callback invoked for each incoming CompletableSubscriber
|
541 | 539 | * @return the new Completable instance
|
542 |
| - * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number) |
| 540 | + * @since 1.3 |
543 | 541 | */
|
544 |
| - @Experimental |
545 | 542 | public static Completable fromEmitter(Action1<CompletableEmitter> producer) {
|
546 | 543 | return create(new CompletableFromEmitter(producer));
|
547 | 544 | }
|
@@ -2385,10 +2382,10 @@ public void call() {
|
2385 | 2382 | * <dt><b>Scheduler:</b></dt>
|
2386 | 2383 | * <dd>{@code test} does not operate by default on a particular {@link Scheduler}.</dd>
|
2387 | 2384 | * </dl>
|
| 2385 | + * <p>History: 1.2.3 - experimental |
2388 | 2386 | * @return the new AssertableSubscriber instance
|
2389 |
| - * @since 1.2.3 |
| 2387 | + * @since 1.3 |
2390 | 2388 | */
|
2391 |
| - @Experimental |
2392 | 2389 | public final AssertableSubscriber<Void> test() {
|
2393 | 2390 | AssertableSubscriberObservable<Void> ts = AssertableSubscriberObservable.create(Long.MAX_VALUE);
|
2394 | 2391 | subscribe(ts);
|
|
0 commit comments