 				if let nextSignalProducer = nextSignalProducer {
 					recur(nextSignalProducer)
 				} else if isComplete {
-					complete💯()
+					sendCompleted(observer)
 				}
 			})
 		}

				}

				if isComplete {
					complete💯()
				}
			})
				

		let state = Atomic(ConcatState<T, E>())
		
		/// Subscribes to the given signal producer.
		let subscribeToSignalProducer: (SignalProducer<T, E> -> Void) = Z { recur, signalProducer in
			let serialDisposable = SerialDisposable()
			let serialDisposableCompositeHandle = disposable.addDisposable(serialDisposable)
			state.modify { (var state) in
