Skip to content

Commit 2234caf

Browse files
Fix Observable.take scheduler annotation (#8289)
1 parent 4e481d5 commit 2234caf

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/main/java/io/reactivex/rxjava4/core/Observable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11489,7 +11489,7 @@ public final Observable<T> take(long count) {
1148911489
* @see <a href="http://reactivex.io/documentation/operators/take.html">ReactiveX operators documentation: Take</a>
1149011490
*/
1149111491
@CheckReturnValue
11492-
@SchedulerSupport(SchedulerSupport.NONE)
11492+
@SchedulerSupport(SchedulerSupport.COMPUTATION)
1149311493
@NonNull
1149411494
public final Observable<T> take(long time, @NonNull TimeUnit unit) {
1149511495
return takeUntil(timer(time, unit));

0 commit comments

Comments
 (0)