             more.append(string)
         })
         subject?.on(.next("1"))
-        XCTAssert(strings?.first == more.first)
+        XCTAssertEqual(strings?.first, more.first)
     }
 
     func testFiresStoppedEventOnSubscribeIfStopped() {

        subject?.on(.next("2"))
        subject?.on(.done)
        subject?.on(.next("3"))
        XCTAssert(strings?.count == 2)
        XCTAssert(strings?[0] == "1")
        XCTAssert(strings?[1] == "2")
        XCTAssert(done == true)
    }

    func testOnError() {

        observable.on(.next("1"))

        waitForExpectations(timeout: 1) { _ in
            XCTAssertEqual(received.count, 1)
            XCTAssertEqual(received.first, "3")
        }
    }

