Hydra_Internals_4.swift

Hydra_Internals_4.swift

private func set(state newState: State<Value>) {
	self.stateQueue.sync {
		guard self.state.isPending else {
			return
		}
		self.state = newState // change state
			
		self.observers.forEach { observer in
			switch (state, observer) {
			case (.resolved(let value), .onResolve(_,_)):
				observer.call(andResolve: value)
			case (.rejected(let error), .onReject(_,_)):
				observer.call(andReject: error)
			default:
				break
			}
		}
	}
}