            .failures()
            .sink(receiveCompletion: { _ in self.completed = true },
                  receiveValue: { errors.append($0) })
        
        subject.send("Hello")
        subject.send("There")
        subject.send("World!")
        subject.send(completion: .failure(.someError))
        
        XCTAssertEqual(errors, [.someError])
        XCTAssertTrue(completed)
    }
}