PerfTests.swift

import XCTest
import ReactiveSwift
import Result

class PerfTests: XCTestCase {
	func testSignalSendEventOneObserver() {
		let (signal, observer) = Signal<Int, NoError>.pipe()
		signal.observe { _ in }

		measure {
			for i in 0 ..< 10000 {
				observer.send(value: i)
			}
		}
	}

	func testSignalSendEventEightObservers() {
		let (signal, observer) = Signal<Int, NoError>.pipe()

		for _ in 0 ..< 8 {
			signal.observe { _ in }
		}

		measure {
			for i in 0 ..< 10000 {
				observer.send(value: i)
			}
		}
	}

	func testNestedProducerSendEventTwoObservers() {
		let (signal, observer) = Signal<Int, NoError>.pipe()
		let producer = SignalProducer<Int, NoError>(signal: signal)
			.map { $0 + 1 }
			.map { $0 + 1 }
			.on { _ in }
			.map { $0 + 1 }
			.map { $0 + 1 }

		for _ in 0 ..< 2 {
			producer.start()
		}

		measure {
			for i in 0 ..< 10000 {
				observer.send(value: i)
			}
		}
	}

	func testNestedProducerMixed() {
		let (signal, observer) = Signal<Int, NoError>.pipe()
		let producer = SignalProducer<Int, NoError>(signal: signal)
			.map { $0 + 1 }
			.map { $0 + 1 }
			.on { _ in }
			.map { $0 + 1 }
			.map { $0 + 1 }

		producer.start()

		measure {
			for i in 0 ..< 10000 {
				let d = producer.start()
				observer.send(value: i)
				d.dispose()
			}
		}
	}

	func testNestedProducerSendEventOneObserver() {
		let (signal, observer) = Signal<Int, NoError>.pipe()
		let producer = SignalProducer<Int, NoError>(signal: signal)
			.map { $0 + 1 }
			.map { $0 + 1 }
			.on { _ in }
			.map { $0 + 1 }
			.map { $0 + 1 }

		producer.start()

		measure {
			for i in 0 ..< 10000 {
				observer.send(value: i)
			}
		}
	}

	func testNestedProducerStarting() {
		let producer = SignalProducer<Int, NoError>(value: 0)
			.map { $0 + 1 }
			.map { $0 + 1 }
			.on { _ in }
			.map { $0 + 1 }
			.map { $0 + 1 }

		measure {
			for i in 0 ..< 10000 {
				producer.start()
			}
		}
	}

	func testNestedProducerStartingDisposing() {
		let producer = SignalProducer<Int, NoError>(value: 0)
			.map { $0 + 1 }
			.map { $0 + 1 }
			.on { _ in }
			.map { $0 + 1 }
			.map { $0 + 1 }

		measure {
			for i in 0 ..< 10000 {
				producer.start().dispose()
			}
		}
	}
}