Skip to content

Commit

Permalink
fun
Browse files Browse the repository at this point in the history
  • Loading branch information
mareklangiewicz committed Nov 30, 2023
1 parent 4986eba commit 16a4a23
Show file tree
Hide file tree
Showing 18 changed files with 18 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject

class RxMockMaybe0<T>(var invocationCheck: () -> Boolean = { true })
class RxMockMaybe0<T: Any>(var invocationCheck: () -> Boolean = { true })
: MaybeObserver<T>, Consumer<T>, () -> Maybe<T> {

var invocations = 0
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject

class RxMockMaybe1<A, T>(var invocationCheck: (A) -> Boolean = { true })
class RxMockMaybe1<A, T: Any>(var invocationCheck: (A) -> Boolean = { true })
: MaybeObserver<T>, Consumer<T>, (A) -> Maybe<T> {

constructor(vararg allowedArgs: A) : this({ it in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject

class RxMockMaybe2<A1, A2, T>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
class RxMockMaybe2<A1, A2, T: Any>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
: MaybeObserver<T>, Consumer<T>, (A1, A2) -> Maybe<T> {

constructor(vararg allowedArgs: Pair<A1, A2>) : this({ a1, a2 -> a1 to a2 in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject

class RxMockMaybe3<A1, A2, A3, T>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
class RxMockMaybe3<A1, A2, A3, T: Any>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
: MaybeObserver<T>, Consumer<T>, (A1, A2, A3) -> Maybe<T> {

constructor(vararg allowedArgs: Triple<A1, A2, A3>) : this({ a1, a2, a3 -> Triple(a1, a2, a3) in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject
import pl.mareklangiewicz.tuplek.Quad

class RxMockMaybe4<A1, A2, A3, A4, T>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : MaybeObserver<T>, Consumer<T>, (A1, A2, A3, A4) -> Maybe<T> {
class RxMockMaybe4<A1, A2, A3, A4, T: Any>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : MaybeObserver<T>, Consumer<T>, (A1, A2, A3, A4) -> Maybe<T> {

constructor(vararg allowedArgs: Quad<A1, A2, A3, A4>) : this({ a1, a2, a3, a4 -> Quad(a1, a2, a3, a4) in allowedArgs })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.MaybeSubject
import pl.mareklangiewicz.tuplek.Jackson

class RxMockMaybe5<A1, A2, A3, A4, A5, T>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : MaybeObserver<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Maybe<T> {
class RxMockMaybe5<A1, A2, A3, A4, A5, T: Any>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : MaybeObserver<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Maybe<T> {

constructor(vararg allowedArgs: Jackson<A1, A2, A3, A4, A5>) : this({ a1, a2, a3, a4, a5 -> Jackson(a1, a2, a3, a4, a5) in allowedArgs })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject

class RxMockObservable0<T>(var invocationCheck: () -> Boolean = { true })
class RxMockObservable0<T: Any>(var invocationCheck: () -> Boolean = { true })
: Observer<T>, Consumer<T>, () -> Observable<T> {

var invocations = 0
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject

class RxMockObservable1<A, T>(var invocationCheck: (A) -> Boolean = { true })
class RxMockObservable1<A, T: Any>(var invocationCheck: (A) -> Boolean = { true })
: Observer<T>, Consumer<T>, (A) -> Observable<T> {

constructor(vararg allowedArgs: A) : this({ it in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject

class RxMockObservable2<A1, A2, T>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
class RxMockObservable2<A1, A2, T: Any>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
: Observer<T>, Consumer<T>, (A1, A2) -> Observable<T> {

constructor(vararg allowedArgs: Pair<A1, A2>) : this({ a1, a2 -> a1 to a2 in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject

class RxMockObservable3<A1, A2, A3, T>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
class RxMockObservable3<A1, A2, A3, T: Any>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
: Observer<T>, Consumer<T>, (A1, A2, A3) -> Observable<T> {

constructor(vararg allowedArgs: Triple<A1, A2, A3>) : this({ a1, a2, a3 -> Triple(a1, a2, a3) in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject
import pl.mareklangiewicz.tuplek.Quad

class RxMockObservable4<A1, A2, A3, A4, T>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : Observer<T>, Consumer<T>, (A1, A2, A3, A4) -> Observable<T> {
class RxMockObservable4<A1, A2, A3, A4, T: Any>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : Observer<T>, Consumer<T>, (A1, A2, A3, A4) -> Observable<T> {

constructor(vararg allowedArgs: Quad<A1, A2, A3, A4>) : this({ a1, a2, a3, a4 -> Quad(a1, a2, a3, a4) in allowedArgs })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import io.reactivex.rxjava3.subjects.PublishSubject
import io.reactivex.rxjava3.subjects.Subject
import pl.mareklangiewicz.tuplek.Jackson

class RxMockObservable5<A1, A2, A3, A4, A5, T>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : Observer<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Observable<T> {
class RxMockObservable5<A1, A2, A3, A4, A5, T: Any>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : Observer<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Observable<T> {

constructor(vararg allowedArgs: Jackson<A1, A2, A3, A4, A5>) : this({ a1, a2, a3, a4, a5 -> Jackson(a1, a2, a3, a4, a5) in allowedArgs })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject

class RxMockSingle0<T>(var invocationCheck: () -> Boolean = { true })
class RxMockSingle0<T: Any>(var invocationCheck: () -> Boolean = { true })
: SingleObserver<T>, Consumer<T>, () -> Single<T> {

var invocations = 0
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject

class RxMockSingle1<A, T>(var invocationCheck: (A) -> Boolean = { true })
class RxMockSingle1<A, T: Any>(var invocationCheck: (A) -> Boolean = { true })
: SingleObserver<T>, Consumer<T>, (A) -> Single<T> {

constructor(vararg allowedArgs: A) : this({ it in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject

class RxMockSingle2<A1, A2, T>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
class RxMockSingle2<A1, A2, T: Any>(var invocationCheck: (A1, A2) -> Boolean = { _, _ -> true })
: SingleObserver<T>, Consumer<T>, (A1, A2) -> Single<T> {

constructor(vararg allowedArgs: Pair<A1, A2>) : this({ a1, a2 -> a1 to a2 in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject

class RxMockSingle3<A1, A2, A3, T>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
class RxMockSingle3<A1, A2, A3, T: Any>(var invocationCheck: (A1, A2, A3) -> Boolean = { _, _, _ -> true })
: SingleObserver<T>, Consumer<T>, (A1, A2, A3) -> Single<T> {

constructor(vararg allowedArgs: Triple<A1, A2, A3>) : this({ a1, a2, a3 -> Triple(a1, a2, a3) in allowedArgs })
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject
import pl.mareklangiewicz.tuplek.Quad

class RxMockSingle4<A1, A2, A3, A4, T>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : SingleObserver<T>, Consumer<T>, (A1, A2, A3, A4) -> Single<T> {
class RxMockSingle4<A1, A2, A3, A4, T: Any>(var invocationCheck: (A1, A2, A3, A4) -> Boolean = { _, _, _, _ -> true }) : SingleObserver<T>, Consumer<T>, (A1, A2, A3, A4) -> Single<T> {

constructor(vararg allowedArgs: Quad<A1, A2, A3, A4>) : this({ a1, a2, a3, a4 -> Quad(a1, a2, a3, a4) in allowedArgs })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import io.reactivex.rxjava3.functions.Consumer
import io.reactivex.rxjava3.subjects.SingleSubject
import pl.mareklangiewicz.tuplek.Jackson

class RxMockSingle5<A1, A2, A3, A4, A5, T>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : SingleObserver<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Single<T> {
class RxMockSingle5<A1, A2, A3, A4, A5, T: Any>(var invocationCheck: (A1, A2, A3, A4, A5) -> Boolean = { _, _, _, _, _ -> true }) : SingleObserver<T>, Consumer<T>, (A1, A2, A3, A4, A5) -> Single<T> {

constructor(vararg allowedArgs: Jackson<A1, A2, A3, A4, A5>) : this({ a1, a2, a3, a4, a5 -> Jackson(a1, a2, a3, a4, a5) in allowedArgs })

Expand Down

0 comments on commit 16a4a23

Please sign in to comment.