@@ -75,7 +75,10 @@ class ActionTests: QuickSpec {
7575 it ( " execute on .next " ) {
7676 scheduler. scheduleAt ( 10 ) { action. inputs. onNext ( " a " ) }
7777 scheduler. start ( )
78- XCTAssertEqual ( inputs. events, [ next ( 10 , " a " ) ] )
78+ XCTAssertEqual ( inputs. events, Recorded . events ( [
79+ . next( 10 , " a " )
80+ ] )
81+ )
7982 XCTAssertEqual ( executions. events. filter { !$0. value. isStopEvent } . count, 1 )
8083 }
8184 it ( " ignore .error events " ) {
@@ -94,26 +97,33 @@ class ActionTests: QuickSpec {
9497 scheduler. scheduleAt ( 10 ) { action. inputs. onNext ( " a " ) }
9598 scheduler. scheduleAt ( 20 ) { action. inputs. onNext ( " b " ) }
9699 scheduler. start ( )
97- XCTAssertEqual ( inputs. events, [
98- next ( 10 , " a " ) ,
99- next ( 20 , " b " ) ,
100- ] )
100+ XCTAssertEqual ( inputs. events, Recorded . events ( [
101+ . next( 10 , " a " ) ,
102+ . next( 20 , " b " ) ,
103+ ] )
104+ )
101105 XCTAssertEqual ( executions. events. filter { !$0. value. isStopEvent } . count, 2 )
102106 XCTAssertEqual ( executions. events. filter { $0. value. isStopEvent } . count, 0 )
103107 }
104108 it ( " not terminate after .error event " ) {
105109 scheduler. scheduleAt ( 10 ) { action. inputs. onError ( TestError) }
106110 scheduler. scheduleAt ( 20 ) { action. inputs. onNext ( " b " ) }
107111 scheduler. start ( )
108- XCTAssertEqual ( inputs. events, [ next ( 20 , " b " ) ] )
112+ XCTAssertEqual ( inputs. events, Recorded . events ( [
113+ . next( 20 , " b " )
114+ ] )
115+ )
109116 XCTAssertEqual ( executions. events. filter { !$0. value. isStopEvent } . count, 1 )
110117 XCTAssertEqual ( executions. events. filter { $0. value. isStopEvent } . count, 0 )
111118 }
112119 it ( " not terminate after .completed event " ) {
113120 scheduler. scheduleAt ( 10 ) { action. inputs. onCompleted ( ) }
114121 scheduler. scheduleAt ( 20 ) { action. inputs. onNext ( " b " ) }
115122 scheduler. start ( )
116- XCTAssertEqual ( inputs. events, [ next ( 20 , " b " ) ] )
123+ XCTAssertEqual ( inputs. events, Recorded . events ( [
124+ . next( 20 , " b " )
125+ ] )
126+ )
117127 XCTAssertEqual ( executions. events. filter { !$0. value. isStopEvent } . count, 1 )
118128 XCTAssertEqual ( executions. events. filter { $0. value. isStopEvent } . count, 0 )
119129 }
@@ -442,9 +452,9 @@ class ActionTests: QuickSpec {
442452
443453 it ( " errors observable receives generated errors " ) {
444454 XCTAssertEqual ( errors. events, Recorded . events ( [
445- . next( 10 , . notEnabled) ,
446- . next( 20 , . notEnabled)
447- ] )
455+ . next( 10 , . notEnabled) ,
456+ . next( 20 , . notEnabled)
457+ ] )
448458 )
449459 }
450460
0 commit comments