 						self.startNextSignalProducer(nextSignalProducer)
 					}
 
+				// Explicitly drop interruped events from inner signals
+				case .Interrupted:
+					break
+
 				default:
 					self.observer.put(event)
 				}

								: state
						}

					default:
						state.withValue { value -> () in
							if value.isLatestIncompleteSignal(innerSignal) {

					case .Completed:
						decrementInFlight()

					// Explicitly drop interruped events from inner signals
					case .Interrupted:
						break
						
					default:
						relayObserver.put(event)
					}
