Updated tests

Author: basvankuijck

CobaltTests/CobaltTests-Requests.swift

@@ -14,6 +14,55 @@ import Foundation
 @testable import Cobalt
 
 class CobaltTestsRequests: CobaltTests {
+    func testRequestQueue() {
+        waitUntil(expectedFulfillmentCount: 2) { done in
+            
+            let accessToken = AccessToken(host: self.config.host!)
+            accessToken.accessToken = "access_token1"
+            accessToken.expireDate = Date(timeIntervalSinceNow: 10)
+            accessToken.grantType = .clientCredentials
+            accessToken.store()
+            
+            let request1 = Request {
+                $0.authentication = .client
+                $0.path = "/some_strange_request"
+                $0.authentication = .oauth2(.clientCredentials)
+            }
+
+            self.client.request(request1).subscribe { event in
+                switch event {
+                case .success:
+                    XCTAssert(false, "Should not get here")
+
+                case .failure:
+                    break
+                }
+                done?()
+            }.disposed(by: self.disposeBag)
+            
+            let request2 = Request {
+                $0.authentication = .client
+                $0.path = "/api/users"
+                $0.parameters = [
+                    "per_page": 10
+                ]
+                $0.authentication = .oauth2(.clientCredentials)
+            }
+
+            self.client.request(request2).subscribe { event in
+                switch event {
+                case .success(let json):
+                    XCTAssert(json["data"].arrayValue.count == 10)
+
+                case .failure(let error):
+                    XCTAssert(false, "\(error)")
+                }
+                done?()
+            }.disposed(by: self.disposeBag)
+        }
+    }
+    
+    
     func testRequestGET() {
         waitUntil { done in
             let request = Request {

CobaltTests/CobaltTests.swift

@@ -30,8 +30,9 @@ class CobaltTests: XCTestCase {
         super.tearDown()
     }
 
-    func waitUntil(_ handler: @escaping (((() -> Void)?) -> Void)) {
+    func waitUntil(expectedFulfillmentCount: Int = 1, _ handler: @escaping (((() -> Void)?) -> Void)) {
         let expectation = self.expectation(description: "test")
+        expectation.expectedFulfillmentCount = expectedFulfillmentCount
         handler({ expectation.fulfill() })
         waitForExpectations(timeout: 15, handler: nil)
     }