Fail when server return code returns an error. (#10)

drrajan · web-flow · commit ed518ac6cb6b · 2021-08-13T16:27:15.000-07:00
diff --git a/Sources/Endpoints/Extensions/URLSession+Combine.swift b/Sources/Endpoints/Extensions/URLSession+Combine.swift
@@ -25,7 +25,6 @@ extension URLSession {
             return Fail(outputType: T.Response.self, failure: T.TaskError.endpointError(error as! EndpointError))
                 .eraseToAnyPublisher()
         }
-        
 
         return dataTaskPublisher(for: urlRequest)
             .subscribe(on: DispatchQueue.global())
@@ -37,7 +36,11 @@ extension URLSession {
 
                 return responseError
             }
-            .map { _ in }
+            .tryMap { result in
+                _ = try T.endpoint.response(data: result.data, response: result.response, error: nil).get()
+            }
+            // swiftlint:disable:next force_cast
+            .mapError { $0 as! T.TaskError }
             .eraseToAnyPublisher()
     }
 

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,6 @@ extension URLSession {`
`25`	`25`	`return Fail(outputType: T.Response.self, failure: T.TaskError.endpointError(error as! EndpointError))`
`26`	`26`	`.eraseToAnyPublisher()`
`27`	`27`	`}`
`28`		`-`
`29`	`28`
`30`	`29`	`return dataTaskPublisher(for: urlRequest)`
`31`	`30`	`.subscribe(on: DispatchQueue.global())`
`@@ -37,7 +36,11 @@ extension URLSession {`
`37`	`36`
`38`	`37`	`return responseError`
`39`	`38`	`}`
`40`		`- .map { _ in }`
	`39`	`+ .tryMap { result in`
	`40`	`+ _ = try T.endpoint.response(data: result.data, response: result.response, error: nil).get()`
	`41`	`+ }`
	`42`	`+ // swiftlint:disable:next force_cast`
	`43`	`+ .mapError { $0 as! T.TaskError }`
`41`	`44`	`.eraseToAnyPublisher()`
`42`	`45`	`}`
`43`	`46`