11import Combine
22import ComposableArchitecture
3+ @_spi ( Concurrency) import Dependencies
34import XCTest
45
56@MainActor
@@ -43,34 +44,36 @@ final class EffectRunTests: BaseTCATestCase {
4344
4445 #if DEBUG
4546 func testRunUnhandledFailure( ) async {
46- var line : UInt !
47- XCTExpectFailure ( nil , enabled: nil , strict: nil ) {
48- $0. compactDescription == """
47+ await withMainSerialExecutor {
48+ var line : UInt !
49+ XCTExpectFailure ( nil , enabled: nil , strict: nil ) {
50+ $0. compactDescription == """
4951 An " EffectTask.run " returned from " \( #fileID) : \( line+ 1 ) " threw an unhandled error. …
5052
5153 EffectRunTests.Failure()
5254
5355 All non-cancellation errors must be explicitly handled via the " catch " parameter on \
5456 " EffectTask.run " , or via a " do " block.
5557 """
56- }
57- struct State : Equatable { }
58- enum Action : Equatable { case tapped, response }
59- let reducer = Reduce < State , Action > { state, action in
60- switch action {
61- case . tapped:
62- line = #line
63- return . run { send in
64- struct Failure : Error { }
65- throw Failure ( )
58+ }
59+ struct State : Equatable { }
60+ enum Action : Equatable { case tapped, response }
61+ let reducer = Reduce < State , Action > { state, action in
62+ switch action {
63+ case . tapped:
64+ line = #line
65+ return . run { send in
66+ struct Failure : Error { }
67+ throw Failure ( )
68+ }
69+ case . response:
70+ return . none
6671 }
67- case . response:
68- return . none
6972 }
73+ let store = TestStore ( initialState: State ( ) , reducer: reducer)
74+ // NB: We wait a long time here because XCTest failures take a long time to generate
75+ await store. send ( . tapped) . finish ( timeout: 5 * NSEC_PER_SEC)
7076 }
71- let store = TestStore ( initialState: State ( ) , reducer: reducer)
72- // NB: We wait a long time here because XCTest failures take a long time to generate
73- await store. send ( . tapped) . finish ( timeout: 5 * NSEC_PER_SEC)
7477 }
7578 #endif
7679
@@ -120,8 +123,9 @@ final class EffectRunTests: BaseTCATestCase {
120123
121124 #if DEBUG
122125 func testRunEscapeFailure( ) async throws {
123- XCTExpectFailure {
124- $0. compactDescription == """
126+ try await withMainSerialExecutor {
127+ XCTExpectFailure {
128+ $0. compactDescription == """
125129 An action was sent from a completed effect:
126130
127131 Action:
@@ -136,32 +140,33 @@ final class EffectRunTests: BaseTCATestCase {
136140 To fix this, make sure that your 'run' closure does not return until you're done calling \
137141 'send'.
138142 """
139- }
143+ }
140144
141- enum Action { case tap, response }
145+ enum Action { case tap, response }
142146
143- let queue = DispatchQueue . test
147+ let queue = DispatchQueue . test
144148
145- let store = Store (
146- initialState: 0 ,
147- reducer: Reduce< Int, Action> { _, action in
148- switch action {
149- case . tap:
150- return . run { send in
151- Task ( priority: . userInitiated) {
152- try await queue. sleep ( for: . seconds( 1 ) )
153- await send ( . response)
149+ let store = Store (
150+ initialState: 0 ,
151+ reducer: Reduce< Int, Action> { _, action in
152+ switch action {
153+ case . tap:
154+ return . run { send in
155+ Task ( priority: . userInitiated) {
156+ try await queue. sleep ( for: . seconds( 1 ) )
157+ await send ( . response)
158+ }
154159 }
160+ case . response:
161+ return . none
155162 }
156- case . response:
157- return . none
158163 }
159- }
160- )
164+ )
161165
162- let viewStore = ViewStore ( store, observe: { $0 } )
163- await viewStore. send ( . tap) . finish ( )
164- await queue. advance ( by: . seconds( 1 ) )
166+ let viewStore = ViewStore ( store, observe: { $0 } )
167+ await viewStore. send ( . tap) . finish ( )
168+ await queue. advance ( by: . seconds( 1 ) )
169+ }
165170 }
166171
167172 func testRunEscapeFailurePublisher( ) async throws {
0 commit comments