Searched refs:emissions (Results 1 – 10 of 10) sorted by relevance
94 val emissions = mutableListOf<PhotopickerConfiguration>() in testConfigurationEmitsFlagChanges() constant95 backgroundScope.launch { configurationManager.configuration.toList(emissions) } in testConfigurationEmitsFlagChanges()109 assertThat(emissions.size).isEqualTo(2) in testConfigurationEmitsFlagChanges()110 assertThat(emissions.first()).isEqualTo(expectedConfiguration) in testConfigurationEmitsFlagChanges()111 assertThat(emissions.last()) in testConfigurationEmitsFlagChanges()138 val emissions = mutableListOf<PhotopickerConfiguration>() in testConfigurationChangesAreBatched() constant139 backgroundScope.launch { configurationManager.configuration.toList(emissions) } in testConfigurationChangesAreBatched()164 assertThat(emissions.size).isEqualTo(2) in testConfigurationChangesAreBatched()165 assertThat(emissions.first()).isEqualTo(expectedConfiguration) in testConfigurationChangesAreBatched()166 assertThat(emissions.last()) in testConfigurationChangesAreBatched()[all …]
119 val emissions = mutableListOf<List<Provider>>() in <lambda>() constant120 this.backgroundScope.launch { dataService.availableProviders.toList(emissions) } in <lambda>()125 assertThat(emissions.count()).isEqualTo(2) in <lambda>()126 assertThat(emissions.get(0)).isEqualTo(emptyList<Provider>()) in <lambda>()128 assertThat(emissions.get(1).count()).isEqualTo(1) in <lambda>()129 assertThat(emissions.get(1).get(0).authority) in <lambda>()148 val emissions = mutableListOf<List<Provider>>() in <lambda>() constant149 this.backgroundScope.launch { dataService.availableProviders.toList(emissions) } in <lambda>()154 assertThat(emissions.count()).isEqualTo(2) in <lambda>()155 assertThat(emissions.get(0)).isEqualTo(emptyList<Provider>()) in <lambda>()[all …]
156 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant157 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()170 val flow = emissions.last() in <lambda>()189 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant190 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()212 .that(emissions.last()) in <lambda>()214 assertWithMessage("Emitted flow has an unexpected size").that(emissions.last()).hasSize(6) in <lambda>()230 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant231 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()246 .that(emissions.first()) in <lambda>()[all …]
152 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant153 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()166 val flow = emissions.last() in <lambda>()185 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant186 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()208 .that(emissions.last()) in <lambda>()210 assertWithMessage("Emitted flow has an unexpected size").that(emissions.last()).hasSize(6) in <lambda>()226 val emissions = mutableListOf<Set<SelectionData>>() in <lambda>() constant227 backgroundScope.launch { selection.flow.toList(emissions) } in <lambda>()242 .that(emissions.first()) in <lambda>()[all …]
111 val emissions = mutableListOf<NetworkStatus>() in testCallbackEmitsNewNetworkStatus() constant112 backgroundScope.launch { networkMonitor.networkStatus.toList(emissions) } in testCallbackEmitsNewNetworkStatus()119 assertThat(emissions.removeFirst()).isEqualTo(NetworkStatus.Available) in testCallbackEmitsNewNetworkStatus()124 assertThat(emissions.removeFirst()).isEqualTo(NetworkStatus.Unavailable) in testCallbackEmitsNewNetworkStatus()129 assertThat(emissions.removeFirst()).isEqualTo(NetworkStatus.Available) in testCallbackEmitsNewNetworkStatus()134 assertThat(emissions.removeFirst()).isEqualTo(NetworkStatus.Unavailable) in testCallbackEmitsNewNetworkStatus()163 val emissions = mutableListOf<NetworkStatus>() in testNetworkStatusReplayedForNewSubscribers() constant164 backgroundScope.launch { networkMonitor.networkStatus.toList(emissions) } in testNetworkStatusReplayedForNewSubscribers()167 assertThat(emissions.first()).isEqualTo(NetworkStatus.Unavailable) in testNetworkStatusReplayedForNewSubscribers()168 assertThat(emissions.size).isEqualTo(1) in testNetworkStatusReplayedForNewSubscribers()[all …]
477 val emissions = mutableListOf<UserStatus>() in <lambda>() constant479 backgroundScope.launch { userMonitor.userStatus.toList(emissions) } in <lambda>()508 assertThat(emissions.size).isEqualTo(2) in <lambda>()509 assertUserStatusIsEqualIgnoringFields(emissions.get(0), initialExpectedStatus) in <lambda>()510 assertUserStatusIsEqualIgnoringFields(emissions.get(1), expectedUpdatedStatus) in <lambda>()531 val emissions = mutableListOf<UserStatus>() in <lambda>() constant533 backgroundScope.launch { userMonitor.userStatus.toList(emissions) } in <lambda>()550 assertThat(emissions.size).isEqualTo(2) in <lambda>()561 assertThat(emissions.size).isEqualTo(2) in <lambda>()582 val emissions = mutableListOf<UserStatus>() in <lambda>() constant[all …]
515 val emissions = mutableListOf<PlaybackInfo>() in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates() constant522 .toList(emissions) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()532 val mediaSizeChangedInfo = emissions.removeFirst() in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()554 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()566 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()578 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()590 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()602 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()614 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()626 .that(emissions.removeFirst()) in testRemotePreviewSurfaceStateChangedCallbackEmitsUpdates()