Emcee

1
import EventBus
2
import Foundation
3
import SynchronousWaiter
4
import XCTest
5

6
final class EventBusTest: XCTestCase {
7
    func testBroadcastingTearDown() throws {
8
        let bus = EventBus()
9
        let stream = Listener()
10
        bus.add(stream: stream)
11
        bus.tearDown()
12
        
13
        try SynchronousWaiter().waitWhile(timeout: 5.0, description: "Waiting for event bus to deliver events") {
14
            stream.didTearDown == nil
15
        }
16
        
17
        XCTAssertTrue(stream.didTearDown == true)
18
    }
19
}
20

21
private final class Listener: DefaultBusListener {
22
    public var didTearDown: Bool?
23
    override func tearDown() {
24
        didTearDown = true
25
    }
26
}
27