diff --git a/Rx.playground/Pages/Connectable_Observable_Operators.xcplaygroundpage/Contents.swift b/Rx.playground/Pages/Connectable_Observable_Operators.xcplaygroundpage/Contents.swift index c366e4a2..d3ffdac5 100644 --- a/Rx.playground/Pages/Connectable_Observable_Operators.xcplaygroundpage/Contents.swift +++ b/Rx.playground/Pages/Connectable_Observable_Operators.xcplaygroundpage/Contents.swift @@ -12,7 +12,7 @@ Specialty Observables that have more precisely-controlled subscription dynamics. func sampleWithoutConnectableOperators() { - let int1 = interval(1, MainScheduler.sharedInstance) + let int1 = interval(1, scheduler: MainScheduler.sharedInstance) _ = int1 .subscribe { @@ -48,7 +48,7 @@ func sampleWithMulticast() { print("Subject \($0)") } - let int1 = interval(1, MainScheduler.sharedInstance) + let int1 = interval(1, scheduler: MainScheduler.sharedInstance) .multicast(subject1) _ = int1 @@ -91,7 +91,7 @@ publish = multicast + replay subject */ func sampleWithReplayBuffer0() { - let int1 = interval(1, MainScheduler.sharedInstance) + let int1 = interval(1, scheduler: MainScheduler.sharedInstance) .replay(0) _ = int1 @@ -126,7 +126,7 @@ func sampleWithReplayBuffer2() { print("--- sampleWithReplayBuffer2 ---\n") - let int1 = interval(1, MainScheduler.sharedInstance) + let int1 = interval(1, scheduler: MainScheduler.sharedInstance) .replay(2) _ = int1 @@ -169,7 +169,7 @@ so publish is basically replay(0) */ func sampleWithPublish() { - let int1 = interval(1, MainScheduler.sharedInstance) + let int1 = interval(1, scheduler: MainScheduler.sharedInstance) .publish() _ = int1 diff --git a/Rx.playground/Pages/Mathematical_and_Aggregate_Operators.xcplaygroundpage/Contents.swift b/Rx.playground/Pages/Mathematical_and_Aggregate_Operators.xcplaygroundpage/Contents.swift index 8ee29c4c..e1ce0689 100644 --- a/Rx.playground/Pages/Mathematical_and_Aggregate_Operators.xcplaygroundpage/Contents.swift +++ b/Rx.playground/Pages/Mathematical_and_Aggregate_Operators.xcplaygroundpage/Contents.swift @@ -66,7 +66,7 @@ This function will perform a function on each element in the sequence until it i */ example("reduce") { _ = sequenceOf(0, 1, 2, 3, 4, 5, 6, 7, 8, 9) - .reduce(0, +) + .reduce(0, accumulator: +) .subscribe { print($0) }