@Test fun `factorial with new combineLatest`() { val observer = TestSubscriber() (1..10).map { it.just() }.combineLatest { it.reduce { one, two -> one * two } }.subscribe(observer) observer.awaitTerminalEvent() observer.assertNoErrors() observer.assertValue(3628800) }