Migrate internal use of Observer.action.

Author: andersio

CHANGELOG.md

@@ -1,6 +1,8 @@
 # master
 *Please add new entries at the top.*
 
+1. `Signal.Observer.action` has been deprecated. Use `Signal.Observer.send` instead. (#515)
+
 1. Workaround an unexpected EGAGIN error being returned by pthread in 32-bit ARM debug builds. (#508)
 
 1. The `SignalProducer` internals have undergone a significant refactoring, which bootstraps the effort to reduce the overhead of constant producers and producer compositions. (#487, kudos to @andersio)

Sources/Action.swift

@@ -161,7 +161,7 @@ public final class Action<Input, Output, Error: Swift.Error> {
 				}
 
 				let interruptHandle = execute(state, input).start { event in
-					observer.action(event.mapError(ActionError.producerFailed))
+					observer.send(event.mapError(ActionError.producerFailed))
 					action.eventsObserver.send(value: event)
 				}
 

Sources/Flatten.swift

@@ -329,7 +329,7 @@ extension Signal where Value: SignalProducerConvertible, Error == Value.Error {
 							}
 
 						case .value, .failed:
-							observer.action(event)
+							observer.send(event)
 						}
 					}
 				}
@@ -592,7 +592,7 @@ extension Signal where Value: SignalProducerConvertible, Error == Value.Error {
 							}
 
 						case .value, .failed:
-							observer.action(event)
+							observer.send(event)
 						}
 					}
 				}
@@ -720,7 +720,7 @@ extension Signal where Value: SignalProducerConvertible, Error == Value.Error {
 							}
 
 						case .value, .failed, .interrupted:
-							observer.action(event)
+							observer.send(event)
 						}
 					}
 				}

Sources/Observer.swift

@@ -123,7 +123,7 @@ extension Signal {
 			self.init { event in
 				switch event {
 				case .value, .completed, .failed:
-					observer.action(event)
+					observer.send(event)
 				case .interrupted:
 					observer.sendCompleted()
 				}

Sources/Property.swift

@@ -553,7 +553,7 @@ public final class Property<Value>: PropertyProtocol {
 				guard let box = box else {
 					// Just forward the event, since no one owns the box or IOW no demand
 					// for a cached latest value.
-					return observer.action(event)
+					return observer.send(event)
 				}
 
 				box.begin { storage in
@@ -562,7 +562,7 @@ public final class Property<Value>: PropertyProtocol {
 							value = newValue
 						}
 					}
-					observer.action(event)
+					observer.send(event)
 				}
 			}
 		}

Sources/Signal.swift

@@ -112,7 +112,7 @@ public final class Signal<Value, Error: Swift.Error> {
 					self.stateLock.unlock()
 
 					for observer in observers {
-						observer.action(event)
+						observer.send(event)
 					}
 				} else {
 					self.stateLock.unlock()
@@ -219,7 +219,7 @@ public final class Signal<Value, Error: Swift.Error> {
 
 					if let event = terminationKind.materialize() {
 						for observer in observers {
-							observer.action(event)
+							observer.send(event)
 						}
 					}
 
@@ -902,7 +902,7 @@ extension Signal {
 					terminated?()
 				}
 
-				observer.action(receivedEvent)
+				observer.send(receivedEvent)
 			}
 
 			return disposable
@@ -1312,14 +1312,14 @@ extension Signal {
 					break
 
 				case .value, .failed, .interrupted:
-					observer.action(event)
+					observer.send(event)
 				}
 			}
 
 			disposable += signalDisposable
 			disposable += signal.observe { event in
 				signalDisposable?.dispose()
-				observer.action(event)
+				observer.send(event)
 			}
 
 			return disposable
@@ -1405,7 +1405,7 @@ extension Signal {
 			disposable += self.observe { event in
 				guard let value = event.value else {
 					schedulerDisposable.inner = scheduler.schedule {
-						observer.action(event)
+						observer.send(event)
 					}
 					return
 				}
@@ -1533,7 +1533,7 @@ extension Signal {
 
 				if let event = eventToSend {
 					schedulerDisposable.inner = scheduler.schedule {
-						observer.action(event)
+						observer.send(event)
 					}
 				}
 			}
@@ -1584,7 +1584,7 @@ extension Signal {
 
 				case .completed, .failed, .interrupted:
 					d.inner = scheduler.schedule {
-						observer.action(event)
+						observer.send(event)
 					}
 				}
 			}
@@ -1869,7 +1869,7 @@ extension Signal {
 			}
 
 			for (index, action) in builder.startHandlers.enumerated() where !disposables.isDisposed {
-				disposables += action(index, strategy) { observer.action($0.map { _ in fatalError() }) }
+				disposables += action(index, strategy) { observer.send($0.map { _ in fatalError() }) }
 			}
 
 			return disposables

Sources/SignalProducer.swift

@@ -1978,7 +1978,7 @@ extension SignalProducer {
 								observer.sendCompleted()
 							}
 						} else {
-							observer.action(event)
+							observer.send(event)
 						}
 					}
 				}
@@ -2271,7 +2271,7 @@ extension SignalProducer {
 						defer { state.enqueue(event) }
 						return state.observers
 					}
-					observers?.forEach { $0.action(event) }
+					observers?.forEach { $0.send(event) }
 				}
 		}
 
@@ -2420,7 +2420,7 @@ private struct ReplayState<Value, Error: Swift.Error> {
 		}
 
 		if let event = terminationEvent {
-			observer.action(event)
+			observer.send(event)
 		}
 
 		return .success(observers?.insert(observer))

Tests/ReactiveSwiftTests/SignalLifetimeSpec.swift

@@ -481,7 +481,7 @@ class SignalLifetimeSpec: QuickSpec {
 private extension Signal {
 	func testTransform() -> Signal<Value, Error> {
 		return Signal { observer in
-			return self.observe(observer.action)
+			return self.observe(observer.send)
 		}
 	}
 }