back to source

Author: kvs-coder

Sources/BlocTest.swift

@@ -8,31 +8,31 @@
 import Foundation
 import Combine
 
-//final public class BlocTest<S: Equatable, B: Base<S>> {
-//    public static func execute(
-//        build: () -> B,
-//        act: ((B) -> Void)?,
-//        wait: TimeInterval? = 0,
-//        expect: (() -> Any)?,
-//        verify: ((Bool, String) -> Void)
-//    ) {
-//        var areEqual = false
-//        var states = [S]()
-//        let bloc = build()
-//        let scheduler = ImmediateScheduler.shared
-//        let cancellable = bloc.$state
-//            .subscribe(on: scheduler)
-//            .delay(for: .seconds(wait ?? 0), scheduler: scheduler)
-//            .sink(receiveValue: { value in
-//                states.append(value)
-//            })
-//        act?(bloc)
-//        if expect != nil {
-//            let expected = expect!()
-//            areEqual = "\(states)" == "\(expected)"
-//            let message = "State received: \(states). \nStates expected: \(expected)"
-//            verify(areEqual, message)
-//        }
-//        cancellable.cancel()
-//    }
-//}
+final public class BlocTest<S: Equatable, B: Base<S>> {
+    public static func execute(
+        build: () -> B,
+        act: ((B) -> Void)?,
+        wait: TimeInterval? = 0,
+        expect: (() -> Any)?,
+        verify: ((Bool, String) -> Void)
+    ) {
+        var areEqual = false
+        var states = [S]()
+        let bloc = build()
+        let scheduler = ImmediateScheduler.shared
+        let cancellable = bloc.$state
+            .subscribe(on: scheduler)
+            .delay(for: .seconds(wait ?? 0), scheduler: scheduler)
+            .sink(receiveValue: { value in
+                states.append(value)
+            })
+        act?(bloc)
+        if expect != nil {
+            let expected = expect!()
+            areEqual = "\(states)" == "\(expected)"
+            let message = "State received: \(states). \nStates expected: \(expected)"
+            verify(areEqual, message)
+        }
+        cancellable.cancel()
+    }
+}

Tests/SwiftBlocTests.swift

@@ -2,36 +2,6 @@ import XCTest
 import Combine
 @testable import SwiftBloc
 
-final public class BlocTest<S: Equatable, B: Base<S>> {
-    public static func execute(
-        build: () -> B,
-        act: ((B) -> Void)?,
-        wait: TimeInterval? = 0,
-        expect: (() -> Any)?,
-        verify: ((Bool, String) -> Void)
-    ) {
-        var areEqual = false
-        var states = [S]()
-        let bloc = build()
-        let scheduler = ImmediateScheduler.shared
-        let cancellable = bloc.$state
-            .subscribe(on: scheduler)
-            .delay(for: .seconds(wait ?? 0), scheduler: scheduler)
-            .sink(receiveValue: { value in
-                states.append(value)
-            })
-        act?(bloc)
-        if expect != nil {
-            let expected = expect!()
-            areEqual = "\(states)" == "\(expected)"
-            let message = "State received: \(states). \nStates expected: \(expected)"
-            verify(areEqual, message)
-        }
-        cancellable.cancel()
-    }
-}
-
-
 final class SwiftBlocTests: XCTestCase {
     func testExample() {
         XCTAssert(true)