@@ -22,77 +22,6 @@ import SPIManifest
22
22
23
23
class ArrayExtensionTests : XCTestCase {
24
24
25
- func test_map_Result_to_EventLoopFuture( ) throws {
26
- // setup
27
- let elg = MultiThreadedEventLoopGroup ( numberOfThreads: 1 )
28
- let results = [ 0 , 1 , 2 ] . map { Result < Int , Error > . success ( $0) }
29
-
30
- // MUT
31
- let mapped = results. map ( on: elg. next ( ) ) {
32
- elg. future ( String ( $0) )
33
- }
34
-
35
- // validate
36
- let res = try mapped. flatten ( on: elg. next ( ) ) . wait ( )
37
- XCTAssertEqual ( res, [ " 0 " , " 1 " , " 2 " ] )
38
- }
39
-
40
- func test_map_Result_to_EventLoopFuture_with_errors( ) throws {
41
- // setup
42
- enum MyError : Error , Equatable { case failed }
43
- let elg = MultiThreadedEventLoopGroup ( numberOfThreads: 1 )
44
- let results : [ Result < Int , MyError > ] = [
45
- . success( 0 ) ,
46
- . failure( MyError . failed) ,
47
- . success( 2 )
48
- ]
49
-
50
- // MUT
51
- let mapped = results. map ( on: elg. next ( ) ) {
52
- elg. future ( String ( $0) )
53
- }
54
-
55
- // validate
56
- XCTAssertEqual ( try mapped [ 0 ] . wait ( ) , " 0 " )
57
- XCTAssertThrowsError ( try mapped [ 1 ] . wait ( ) ) {
58
- XCTAssertEqual ( $0 as? MyError , MyError . failed)
59
- }
60
- XCTAssertEqual ( try mapped [ 2 ] . wait ( ) , " 2 " )
61
- }
62
-
63
- func test_whenAllComplete( ) throws {
64
- // setup
65
- let elg = MultiThreadedEventLoopGroup ( numberOfThreads: 1 )
66
- let results = [ 0 , 1 , 2 ] . map { Result < Int , Error > . success ( $0) }
67
-
68
- // MUT
69
- let res = try results. whenAllComplete ( on: elg. next ( ) ) {
70
- elg. future ( String ( $0) )
71
- } . wait ( )
72
-
73
- // validate
74
- XCTAssertEqual ( res. compactMap { try ? $0. get ( ) } , [ " 0 " , " 1 " , " 2 " ] )
75
- }
76
-
77
- func test_whenAllComplete_with_errors( ) throws {
78
- // setup
79
- enum MyError : Error { case failed }
80
- let elg = MultiThreadedEventLoopGroup ( numberOfThreads: 1 )
81
- let results : [ Result < Int , Error > ] = [
82
- . success( 0 ) ,
83
- . failure( MyError . failed) ,
84
- . success( 2 )
85
- ]
86
-
87
- // MUT
88
- let res = try results. whenAllComplete ( on: elg. next ( ) ) {
89
- elg. future ( String ( $0) )
90
- } . wait ( )
91
-
92
- // validate
93
- XCTAssertEqual ( res. compactMap { try ? $0. get ( ) } , [ " 0 " , " 2 " ] )
94
- }
95
-
96
25
func test_defaultBranchVersion( ) throws {
97
26
XCTAssertEqual (
98
27
[
0 commit comments