@@ -9,7 +9,7 @@ private val onErrorStub: (Throwable) -> Unit = { throw OnErrorNotImplementedExce
9
9
private val onCompleteStub: () -> Unit = {}
10
10
11
11
/* *
12
- * Overloaded subscribe function that allow passing named parameters
12
+ * Overloaded subscribe function that allows passing named parameters
13
13
*/
14
14
fun <T : Any > Observable<T>.subscribeBy (
15
15
onNext : (T ) -> Unit = onNextStub,
@@ -18,7 +18,7 @@ fun <T : Any> Observable<T>.subscribeBy(
18
18
): Disposable = subscribe(onNext, onError, onComplete)
19
19
20
20
/* *
21
- * Overloaded subscribe function that allow passing named parameters
21
+ * Overloaded subscribe function that allows passing named parameters
22
22
*/
23
23
fun <T : Any > Flowable<T>.subscribeBy (
24
24
onNext : (T ) -> Unit = onNextStub,
@@ -27,15 +27,15 @@ fun <T : Any> Flowable<T>.subscribeBy(
27
27
): Disposable = subscribe(onNext, onError, onComplete)
28
28
29
29
/* *
30
- * Overloaded subscribe function that allow passing named parameters
30
+ * Overloaded subscribe function that allows passing named parameters
31
31
*/
32
32
fun <T : Any > Single<T>.subscribeBy (
33
33
onSuccess : (T ) -> Unit = onNextStub,
34
34
onError : (Throwable ) -> Unit = onErrorStub
35
35
): Disposable = subscribe(onSuccess, onError)
36
36
37
37
/* *
38
- * Overloaded subscribe function that allow passing named parameters
38
+ * Overloaded subscribe function that allows passing named parameters
39
39
*/
40
40
fun <T : Any > Maybe<T>.subscribeBy (
41
41
onSuccess : (T ) -> Unit = onNextStub,
@@ -44,15 +44,15 @@ fun <T : Any> Maybe<T>.subscribeBy(
44
44
): Disposable = subscribe(onSuccess, onError, onComplete)
45
45
46
46
/* *
47
- * Overloaded subscribe function that allow passing named parameters
47
+ * Overloaded subscribe function that allows passing named parameters
48
48
*/
49
49
fun Completable.subscribeBy (
50
50
onError : (Throwable ) -> Unit = onErrorStub,
51
51
onComplete : () -> Unit = onCompleteStub
52
52
): Disposable = subscribe(onComplete, onError)
53
53
54
54
/* *
55
- * Overloaded blockingSubscribe function that allow passing named parameters
55
+ * Overloaded blockingSubscribe function that allows passing named parameters
56
56
*/
57
57
fun <T : Any > Observable<T>.blockingSubscribeBy (
58
58
onNext : (T ) -> Unit = onNextStub,
@@ -61,7 +61,7 @@ fun <T : Any> Observable<T>.blockingSubscribeBy(
61
61
) = blockingSubscribe(onNext, onError, onComplete)
62
62
63
63
/* *
64
- * Overloaded blockingSubscribe function that allow passing named parameters
64
+ * Overloaded blockingSubscribe function that allows passing named parameters
65
65
*/
66
66
fun <T : Any > Flowable<T>.blockingSubscribeBy (
67
67
onNext : (T ) -> Unit = onNextStub,
0 commit comments