Add Schedulers.trampoline() to SchedulerHandlers

so the response from FakeCallRecordingRepository is received in CallRecordingViewModelTest

Signed-off-by: Marcel Hibbe <dev@mhibbe.de>
This commit is contained in:
Marcel Hibbe 2023-01-31 10:15:04 +01:00
parent 5cc2a6d531
commit 724f41a3be
No known key found for this signature in database
GPG Key ID: C793F8B59F43CE7B
3 changed files with 15 additions and 4 deletions

View File

@ -31,12 +31,12 @@ class FakeCallRecordingRepository : CallRecordingRepository {
override fun startRecording(
roomToken: String
): Observable<StartCallRecordingModel> {
return Observable.just<StartCallRecordingModel>(StartCallRecordingModel(true))
return Observable.just(StartCallRecordingModel(true))
}
override fun stopRecording(
roomToken: String
): Observable<StopCallRecordingModel> {
return Observable.just<StopCallRecordingModel>(StopCallRecordingModel(true))
return Observable.just(StopCallRecordingModel(true))
}
}

View File

@ -2,6 +2,7 @@ package com.nextcloud.talk.viewmodels
import androidx.arch.core.executor.testing.InstantTaskExecutorRule
import io.reactivex.android.plugins.RxAndroidPlugins
import io.reactivex.plugins.RxJavaPlugins
import io.reactivex.schedulers.Schedulers
import org.junit.BeforeClass
import org.junit.Rule
@ -14,6 +15,16 @@ open class AbstractViewModelTest {
@JvmStatic
@BeforeClass
fun setUpClass() {
RxJavaPlugins.setIoSchedulerHandler {
Schedulers.trampoline()
}
RxJavaPlugins.setComputationSchedulerHandler {
Schedulers.trampoline()
}
RxJavaPlugins.setNewThreadSchedulerHandler {
Schedulers.trampoline()
}
RxAndroidPlugins.setInitMainThreadSchedulerHandler {
Schedulers.trampoline()
}

View File

@ -8,7 +8,7 @@ import org.mockito.MockitoAnnotations
class CallRecordingViewModelTest : AbstractViewModelTest() {
val repository = FakeCallRecordingRepository()
private val repository = FakeCallRecordingRepository()
@Before
fun setUp() {
@ -38,7 +38,7 @@ class CallRecordingViewModelTest : AbstractViewModelTest() {
viewModel.stopRecording()
Assert.equals(CallRecordingViewModel.RecordingStopLoadingState, viewModel.viewState.value)
Assert.equals(CallRecordingViewModel.RecordingStoppedState, viewModel.viewState.value)
}
@Test