Skip to content

Commit 58c87a0

Browse files
committed
Made Signal.flatMapEvent internal. Added docs.
1 parent b0e1020 commit 58c87a0

File tree

2 files changed

+18
-5
lines changed

2 files changed

+18
-5
lines changed

Sources/Signal.swift

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -527,14 +527,17 @@ extension Signal where Error == NoError {
527527
}
528528

529529
extension Signal {
530-
/// Map each value in the signal to a new value.
530+
/// Perform an action upon every event from `self`. The action may generate zero or
531+
/// more events.
532+
///
533+
/// - precondition: The action must be synchronous.
531534
///
532535
/// - parameters:
533-
/// - transform: A closure that accepts a value from the `value` event and
534-
/// returns a new value.
536+
/// - transform: A closure that creates the said action from the given event
537+
/// closure.
535538
///
536-
/// - returns: A signal that will send new values.
537-
public func flatMapEvent<U, E>(_ transform: @escaping (@escaping Signal<U, E>.Observer.Action) -> (Event) -> Void) -> Signal<U, E> {
539+
/// - returns: A signal that forwards events yielded by the action.
540+
internal func flatMapEvent<U, E>(_ transform: @escaping (@escaping Signal<U, E>.Observer.Action) -> (Event) -> Void) -> Signal<U, E> {
538541
return Signal<U, E> { observer in
539542
return self.observe(.init(observer, transform))
540543
}

Sources/SignalProducer.swift

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -243,6 +243,16 @@ internal class SignalProducerCore<Value, Error: Swift.Error> {
243243
return disposable
244244
}
245245

246+
/// Perform an action upon every event from `self`. The action may generate zero or
247+
/// more events.
248+
///
249+
/// - precondition: The action must be synchronous.
250+
///
251+
/// - parameters:
252+
/// - transform: A closure that creates the said action from the given event
253+
/// closure.
254+
///
255+
/// - returns: A producer that forwards events yielded by the action.
246256
internal func flatMapEvent<U, E>(_ transform: @escaping (@escaping Signal<U, E>.Observer.Action) -> (Signal<Value, Error>.Event) -> Void) -> SignalProducer<U, E> {
247257
return SignalProducer<U, E>(EventTransformingCore(source: self, transform: transform))
248258
}

0 commit comments

Comments
 (0)