Skip to content

Commit 29eae30

Browse files
committed
refactor ObservableKt to Observables, FlowableKt to Flowables, etc.
1 parent c193863 commit 29eae30

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

src/main/kotlin/io/reactivex/rxkotlin/FlowableKt.kt renamed to src/main/kotlin/io/reactivex/rxkotlin/Flowables.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import io.reactivex.functions.Function5
88
import org.reactivestreams.Publisher
99

1010

11-
object FlowableKt {
11+
object Flowables {
1212

1313
inline fun <T1,T2,R> combineLatest(source1: Flowable<T1>, source2: Flowable<T2>, crossinline combineFunction: (T1, T2) -> R) =
1414
Flowable.combineLatest(source1, source2,

src/main/kotlin/io/reactivex/rxkotlin/MaybeKt.kt renamed to src/main/kotlin/io/reactivex/rxkotlin/Maybes.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import io.reactivex.Maybe
44
import io.reactivex.MaybeSource
55
import io.reactivex.functions.BiFunction
66

7-
object MaybeKt {
7+
object Maybes {
88
inline fun <T, U, R> zip(s1: MaybeSource<T>, s2: MaybeSource<U>, crossinline zipper: (T, U) -> R): MaybeSource<R>
99
= Maybe.zip(s1,s2, BiFunction { t, u -> zipper.invoke(t, u) })
1010
}

src/main/kotlin/io/reactivex/rxkotlin/ObservableKt.kt renamed to src/main/kotlin/io/reactivex/rxkotlin/Observables.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import io.reactivex.functions.BiFunction
77
/**
88
* SAM adapters to aid Kotlin lambda support
99
*/
10-
object ObservableKt {
10+
object Observables {
1111

1212
inline fun <T1,T2,R> combineLatest(source1: Observable<T1>, source2: Observable<T2>, crossinline combineFunction: (T1, T2) -> R) =
1313
Observable.combineLatest(source1, source2,

src/main/kotlin/io/reactivex/rxkotlin/SingleKt.kt renamed to src/main/kotlin/io/reactivex/rxkotlin/Singles.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import io.reactivex.SingleSource
55
import io.reactivex.functions.BiFunction
66

77

8-
object SingleKt {
8+
object Singles {
99
inline fun <T, U, R> zip(s1: SingleSource<T>, s2: SingleSource<U>, crossinline zipper: (T, U) -> R): Single<R>
1010
= Single.zip(s1,s2, BiFunction { t, u -> zipper.invoke(t, u) })
1111
}

0 commit comments

Comments
 (0)