Skip to content

Commit 0fba7c5

Browse files
He-Pinakarnokd
authored andcommitted
Add FunctionalInterface annotations. (#6773)
1 parent 6ba932c commit 0fba7c5

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

46 files changed

+46
-0
lines changed

src/main/java/io/reactivex/rxjava3/core/CompletableConverter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
* @param <R> the output type
2323
* @since 2.2
2424
*/
25+
@FunctionalInterface
2526
public interface CompletableConverter<R> {
2627
/**
2728
* Applies a function to the upstream Completable and returns a converted value of type {@code R}.

src/main/java/io/reactivex/rxjava3/core/CompletableOnSubscribe.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
* an instance of a {@link CompletableEmitter} instance that allows pushing
2020
* an event in a cancellation-safe manner.
2121
*/
22+
@FunctionalInterface
2223
public interface CompletableOnSubscribe {
2324

2425
/**

src/main/java/io/reactivex/rxjava3/core/CompletableOperator.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
/**
1919
* Interface to map/wrap a downstream observer to an upstream observer.
2020
*/
21+
@FunctionalInterface
2122
public interface CompletableOperator {
2223
/**
2324
* Applies a function to the child CompletableObserver and returns a new parent CompletableObserver.

src/main/java/io/reactivex/rxjava3/core/CompletableSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
*
2121
* @since 2.0
2222
*/
23+
@FunctionalInterface
2324
public interface CompletableSource {
2425

2526
/**

src/main/java/io/reactivex/rxjava3/core/CompletableTransformer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
* Convenience interface and callback used by the compose operator to turn a Completable into another
2020
* Completable fluently.
2121
*/
22+
@FunctionalInterface
2223
public interface CompletableTransformer {
2324
/**
2425
* Applies a function to the upstream Completable and returns a CompletableSource.

src/main/java/io/reactivex/rxjava3/core/FlowableConverter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
* @param <R> the output type
2424
* @since 2.2
2525
*/
26+
@FunctionalInterface
2627
public interface FlowableConverter<T, R> {
2728
/**
2829
* Applies a function to the upstream Flowable and returns a converted value of type {@code R}.

src/main/java/io/reactivex/rxjava3/core/FlowableOnSubscribe.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
*
2222
* @param <T> the value type pushed
2323
*/
24+
@FunctionalInterface
2425
public interface FlowableOnSubscribe<T> {
2526

2627
/**

src/main/java/io/reactivex/rxjava3/core/FlowableOperator.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
* @param <Downstream> the value type of the downstream
2424
* @param <Upstream> the value type of the upstream
2525
*/
26+
@FunctionalInterface
2627
public interface FlowableOperator<Downstream, Upstream> {
2728
/**
2829
* Applies a function to the child Subscriber and returns a new parent Subscriber.

src/main/java/io/reactivex/rxjava3/core/FlowableTransformer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
* @param <Upstream> the upstream value type
2424
* @param <Downstream> the downstream value type
2525
*/
26+
@FunctionalInterface
2627
public interface FlowableTransformer<Upstream, Downstream> {
2728
/**
2829
* Applies a function to the upstream Flowable and returns a Publisher with

src/main/java/io/reactivex/rxjava3/core/MaybeConverter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
* @param <R> the output type
2424
* @since 2.2
2525
*/
26+
@FunctionalInterface
2627
public interface MaybeConverter<T, R> {
2728
/**
2829
* Applies a function to the upstream Maybe and returns a converted value of type {@code R}.

0 commit comments

Comments
 (0)