ObserverOverheadTests.swift

import XCTest
import ReactiveSwift
import Result

class Test: XCTestCase {

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

		let transformed = signal
			.map { $0 + Int(arc4random() % 5 as UInt32) }
			.map { $0 + Int(arc4random() % 4 as UInt32) }
			.map { $0 + Int(arc4random() % 3 as UInt32) }
			.map { $0 + Int(arc4random() % 2 as UInt32) }

		var values: [Int] = []

		transformed.observeValues { value in
			if !values.contains(value) {
				values.append(value)
			}
		}

		self.measure {
			for _ in 1 ... 10000 {
				observer.send(value: Int(arc4random() % 5) - 4)
			}
		}
	}
}