Add tests for bind to multiple relays

ReactiveX · Apr 9, 2019 · ba5cb7a · ba5cb7a
1 parent 1a630a6
commit ba5cb7a
Showing 1 changed file with 76 additions and 3 deletions.
diff --git a/Tests/RxCocoaTests/Observable+BindTests.swift b/Tests/RxCocoaTests/Observable+BindTests.swift
@@ -152,7 +152,7 @@ extension ObservableBindTest {
 
         let relay = PublishRelay<Int>()
 
-        _ = relay.subscribe{ event in
+        _ = relay.subscribe { event in
             events.append(Recorded(time: 0, value: event))
         }
 
@@ -162,13 +162,39 @@ extension ObservableBindTest {
             .next(1)
             ])
     }
+
+    func testBindToPublishRelays() {
+        var events1: [Recorded<Event<Int>>] = []
+        var events2: [Recorded<Event<Int>>] = []
+
+        let relay1 = PublishRelay<Int>()
+        let relay2 = PublishRelay<Int>()
+
+        _ = relay1.subscribe { event in
+            events1.append(Recorded(time: 0, value: event))
+        }
+
+        _ = relay2.subscribe { event in
+            events2.append(Recorded(time: 0, value: event))
+        }
+
+        _ = Observable.just(1).bind(to: relay1, relay2)
+
+        XCTAssertEqual(events1, [
+            .next(1)
+            ])
+
+        XCTAssertEqual(events2, [
+            .next(1)
+            ])
+    }
 
     func testBindToOptionalPublishRelay() {
         var events: [Recorded<Event<Int?>>] = []
 
         let relay = PublishRelay<Int?>()
 
-        _ = relay.subscribe{ event in
+        _ = relay.subscribe { event in
             events.append(Recorded(time: 0, value: event))
         }
 
@@ -179,12 +205,38 @@ extension ObservableBindTest {
             ])
     }
 
+    func testBindToOptionalPublishRelays() {
+        var events1: [Recorded<Event<Int?>>] = []
+        var events2: [Recorded<Event<Int?>>] = []
+
+        let relay1 = PublishRelay<Int?>()
+        let relay2 = PublishRelay<Int?>()
+
+        _ = relay1.subscribe { event in
+            events1.append(Recorded(time: 0, value: event))
+        }
+
+        _ = relay2.subscribe { event in
+            events2.append(Recorded(time: 0, value: event))
+        }
+
+        _ = Observable.just(1).bind(to: relay1, relay2)
+
+        XCTAssertEqual(events1, [
+            .next(1)
+            ])
+
+        XCTAssertEqual(events2, [
+            .next(1)
+            ])
+    }
+
     func testBindToPublishRelayNoAmbiguity() {
         var events: [Recorded<Event<Int?>>] = []
 
         let relay = PublishRelay<Int?>()
 
-        _ = relay.subscribe{ event in
+        _ = relay.subscribe { event in
             events.append(Recorded(time: 0, value: event))
         }
 
@@ -206,6 +258,17 @@ extension ObservableBindTest {
 
         XCTAssertEqual(relay.value, 1)
     }
+
+
+    func testBindToBehaviorRelays() {
+        let relay1 = BehaviorRelay<Int>(value: 0)
+        let relay2 = BehaviorRelay<Int>(value: 0)
+
+        _ = Observable.just(1).bind(to: relay1, relay2)
+
+        XCTAssertEqual(relay1.value, 1)
+        XCTAssertEqual(relay2.value, 1)
+    }
 
     func testBindToOptionalBehaviorRelay() {
         let relay = BehaviorRelay<Int?>(value: 0)
@@ -215,6 +278,16 @@ extension ObservableBindTest {
         XCTAssertEqual(relay.value, 1)
     }
 
+    func testBindToOptionalBehaviorRelays() {
+        let relay1 = BehaviorRelay<Int?>(value: 0)
+        let relay2 = BehaviorRelay<Int?>(value: 0)
+
+        _ = Observable.just(1).bind(to: relay1, relay2)
+
+        XCTAssertEqual(relay1.value, 1)
+        XCTAssertEqual(relay2.value, 1)
+    }
+
     func testBindToBehaviorRelayNoAmbiguity() {
         let relay = BehaviorRelay<Int?>(value: 0)