@@ -393,7 +393,7 @@ extension SignalProducer {
393393 public func concat( _ next: SignalProducer < Value , Error > ) -> SignalProducer < Value , Error > {
394394 return SignalProducer < SignalProducer < Value , Error > , Error > ( [ self . producer, next ] ) . flatten ( . concat)
395395 }
396-
396+
397397 /// `concat`s `value` onto `self`.
398398 ///
399399 /// - parameters:
@@ -404,7 +404,7 @@ extension SignalProducer {
404404 public func concat( value: Value ) -> SignalProducer < Value , Error > {
405405 return self . concat ( SignalProducer ( value: value) )
406406 }
407-
407+
408408 /// `concat`s `self` onto initial `previous`.
409409 ///
410410 /// - parameters:
@@ -415,7 +415,7 @@ extension SignalProducer {
415415 public func prefix( _ previous: SignalProducer < Value , Error > ) -> SignalProducer < Value , Error > {
416416 return previous. concat ( self )
417417 }
418-
418+
419419 /// `concat`s `self` onto initial `value`.
420420 ///
421421 /// - parameters:
@@ -433,10 +433,10 @@ private final class ConcurrentFlattenState<Value, Error: Swift.Error> {
433433
434434 /// The limit of active producers.
435435 let limit : UInt
436-
436+
437437 /// The number of active producers.
438438 var activeCount : UInt = 0
439-
439+
440440 /// The producers waiting to be started.
441441 var queue : [ Producer ] = [ ]
442442
@@ -451,7 +451,7 @@ private final class ConcurrentFlattenState<Value, Error: Swift.Error> {
451451 init ( limit: UInt ) {
452452 self . limit = limit
453453 }
454-
454+
455455 /// Dequeue the next producer if one should be started.
456456 ///
457457 /// - returns: The `Producer` to start or `nil` if no producer should be
@@ -489,7 +489,7 @@ extension Signal {
489489 . flatten ( . merge)
490490 . startAndRetrieveSignal ( )
491491 }
492-
492+
493493 /// Merges the given signals into a single `Signal` that will emit all
494494 /// values from each of them, and complete when all of them have completed.
495495 ///
@@ -511,7 +511,7 @@ extension SignalProducer {
511511 {
512512 return SignalProducer < Seq . Iterator . Element , NoError > ( producers) . flatten ( . merge)
513513 }
514-
514+
515515 /// Merges the given producers into a single `SignalProducer` that will emit
516516 /// all values from each of them, and complete when all of them have
517517 /// completed.
@@ -645,7 +645,7 @@ extension SignalProducer where Value: SignalProducerConvertible, Error == Value.
645645private struct LatestState < Value, Error: Swift . Error > {
646646 var outerSignalComplete : Bool = false
647647 var innerSignalComplete : Bool = true
648-
648+
649649 var replacingInnerSignal : Bool = false
650650}
651651
@@ -790,7 +790,7 @@ extension Signal {
790790 public func flatMap< Inner: SignalProducerConvertible > ( _ strategy: FlattenStrategy , _ transform: @escaping ( Value ) -> Inner ) -> Signal < Inner . Value , Error > where Inner. Error == Error {
791791 return map ( transform) . flatten ( strategy)
792792 }
793-
793+
794794 /// Maps each event from `signal` to a new signal, then flattens the
795795 /// resulting producers (into a signal of values), according to the
796796 /// semantics of the given strategy.
@@ -822,7 +822,7 @@ extension Signal where Error == NoError {
822822 public func flatMap< Inner: SignalProducerConvertible > ( _ strategy: FlattenStrategy , _ transform: @escaping ( Value ) -> Inner ) -> Signal < Inner . Value , Inner . Error > {
823823 return map ( transform) . flatten ( strategy)
824824 }
825-
825+
826826 /// Maps each event from `signal` to a new signal, then flattens the
827827 /// resulting signals (into a signal of values), according to the
828828 /// semantics of the given strategy.
@@ -851,7 +851,7 @@ extension SignalProducer {
851851 public func flatMap< Inner: SignalProducerConvertible > ( _ strategy: FlattenStrategy , _ transform: @escaping ( Value ) -> Inner ) -> SignalProducer < Inner . Value , Error > where Inner. Error == Error {
852852 return map ( transform) . flatten ( strategy)
853853 }
854-
854+
855855 /// Maps each event from `self` to a new producer, then flattens the
856856 /// resulting producers (into a producer of values), according to the
857857 /// semantics of the given strategy.
@@ -880,7 +880,7 @@ extension SignalProducer where Error == NoError {
880880 public func flatMap< Inner: SignalProducerConvertible > ( _ strategy: FlattenStrategy , _ transform: @escaping ( Value ) -> Inner ) -> SignalProducer < Inner . Value , Error > where Inner. Error == Error {
881881 return map ( transform) . flatten ( strategy)
882882 }
883-
883+
884884 /// Maps each event from `self` to a new producer, then flattens the
885885 /// resulting producers (into a producer of values), according to the
886886 /// semantics of the given strategy.
@@ -897,7 +897,6 @@ extension SignalProducer where Error == NoError {
897897 }
898898}
899899
900-
901900extension Signal {
902901 /// Catches any failure that may occur on the input signal, mapping to a new
903902 /// producer that starts in its place.
0 commit comments