@@ -235,28 +235,26 @@ class UploadStarterTest : BaseUnitTest() {
235235
236236 @Test
237237 fun `given an unexpected mutex unlock, when uploading, then all other sites are uploaded` () = test {
238- val (first, last) = createSiteModel() to createSiteModel()
239- val posts = createLocallyChangedPostModel() to createLocallyChangedPostModel()
238+ val (first, last) = createLocallyChangedPostModel() to createLocallyChangedPostModel()
240239 val page = createLocallyChangedPostModel(page = true )
241- val starter = createUploadStarter(
240+ whenever(uploadServiceFacade.uploadPost(any(), eq(first), any())).thenAnswer {
241+ mutex.unlock()
242+ }
243+ val (firstSite, lastSite) = createSiteModel() to createSiteModel()
244+ createUploadStarter(
242245 postStore = mock {
243- on { getPostsWithLocalChanges(first ) } doReturn listOf (posts. first)
244- on { getPostsWithLocalChanges(last ) } doReturn listOf (posts.second )
246+ on { getPostsWithLocalChanges(firstSite ) } doReturn listOf (first)
247+ on { getPostsWithLocalChanges(lastSite ) } doReturn listOf (last )
245248 },
246249 pageStore = mock { onBlocking { getPagesWithLocalChanges(any()) } doReturn listOf (page) },
247250 siteStore = mock { on { sites } doReturn sites.toList() },
248- )
249- whenever(uploadServiceFacade.uploadPost(any(), eq(page), any())).thenAnswer {
250- mutex.unlock()
251- }
252-
253- starter.run {
251+ ).run {
254252 launch {
255- queueUploadFromSite(first )
253+ queueUploadFromSite(firstSite )
256254 }
257255 launch {
258256 delay(1500 )
259- queueUploadFromSite(last )
257+ queueUploadFromSite(lastSite )
260258 delay(500 )
261259 }.cancel()
262260 launch {
0 commit comments