Rethrows & refactoring (#34)

Asynchrone/Source/Common/RethrowingAccessor.swift

@@ -0,0 +1,26 @@
+import Foundation
+
+@rethrows
+protocol RethrowingAccessor {
+    associatedtype T
+    func _value() throws ->  T
+}
+
+extension RethrowingAccessor {
+    func _forceRethrowError() rethrows {
+        _ = try _retrowValue()
+        fatalError("No error")
+    }
+
+    func _retrowValue() rethrows -> T {
+        try self._value()
+    }
+}
+
+// MARK: Result
+
+extension Result: RethrowingAccessor {
+    func _value() throws -> Success {
+        try self.get()
+    }
+}

Asynchrone/Source/Sequences/AnyAsyncSequenceable.swift

@@ -2,8 +2,6 @@
 ///
 /// If the async sequence that you wish to type erase can throw, then use `AnyThrowingAsyncSequenceable`.
 public struct AnyAsyncSequenceable<Element>: AsyncSequence {
-
-    // Private
     private var _next: () async -> Element?
     private var _makeAsyncIterator: () -> Self
 
@@ -38,21 +36,16 @@ public struct AnyAsyncSequenceable<Element>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension AnyAsyncSequenceable: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async -> Element? {
         await self._next()
     }
 }
 
-
-
-
 // MARK: Erasure
 
 extension AsyncSequence {
-
     /// Creates a type erasing async sequence.
     ///
     /// If the async sequence that you wish to type erase can throw,

Asynchrone/Source/Sequences/AnyThrowingAsyncSequenceable.swift

@@ -2,8 +2,6 @@
 ///
 /// If the async sequence that you wish to type erase doesn't throw, then use `AnyAsyncSequenceable`.
 public struct AnyThrowingAsyncSequenceable<Element>: AsyncSequence {
-
-    // Private
     private var _next: () async throws -> Element?
     private var _makeAsyncIterator: () -> Self
 
@@ -38,17 +36,13 @@ public struct AnyThrowingAsyncSequenceable<Element>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension AnyThrowingAsyncSequenceable: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async throws -> Element? {
         try await self._next()
     }
 }
 
-
-
-
 // MARK: Erasure
 
 extension AsyncSequence {

Asynchrone/Source/Sequences/AsyncSequenceCompletion.swift

@@ -1,6 +1,5 @@
 /// Describes how an async sequence has completed.
 public enum AsyncSequenceCompletion<Failure: Error> {
-
     /// The async sequence finished normally.
     case finished
 

Asynchrone/Source/Sequences/ChainAsyncSequenceable.swift

@@ -41,7 +41,6 @@
 /// // 9
 /// ```
 public struct ChainAsyncSequence<P: AsyncSequence, Q: AsyncSequence>: AsyncSequence where P.Element == Q.Element {
-
     /// The kind of elements streamed.
     public typealias Element = P.Element
 
@@ -81,9 +80,6 @@ public struct ChainAsyncSequence<P: AsyncSequence, Q: AsyncSequence>: AsyncSeque
 // MARK: AsyncIteratorProtocol
 
 extension ChainAsyncSequence: AsyncIteratorProtocol {
-
-    /// Produces the next element in the sequence.
-    /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async rethrows -> Element? {
         if let element = try await self.iteratorP.next() {
             return element
@@ -93,12 +89,9 @@ extension ChainAsyncSequence: AsyncIteratorProtocol {
     }
 }
 
-
-
 // MARK: Chain
 
 extension AsyncSequence {
-
     /// An asynchronous sequence that chains two async sequences.
     ///
     /// The combined sequence first emits the all the values from the first sequence

Asynchrone/Source/Sequences/CombineLatest3AsyncSequence.swift

@@ -41,7 +41,6 @@
 /// // (4, 9, 11)
 /// ```
 public struct CombineLatest3AsyncSequence<P: AsyncSequence, Q: AsyncSequence, R: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = (P.Element, Q.Element, R.Element)
 
@@ -93,7 +92,6 @@ public struct CombineLatest3AsyncSequence<P: AsyncSequence, Q: AsyncSequence, R:
 // MARK: AsyncIteratorProtocol
 
 extension CombineLatest3AsyncSequence: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     ///
     /// Continues to call `next()` on it's base iterator and iterator of
@@ -134,12 +132,9 @@ extension CombineLatest3AsyncSequence: AsyncIteratorProtocol {
     }
 }
 
-
-
 // MARK: Combine latest
 
 extension AsyncSequence {
-
     /// Combine three async sequences.
     ///
     /// The combined sequence emits a tuple of the most-recent elements from each sequence

Asynchrone/Source/Sequences/CombineLatestAsyncSequence.swift

@@ -35,7 +35,6 @@
 /// // (4, 9)
 /// ```
 public struct CombineLatestAsyncSequence<P: AsyncSequence, Q: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = (P.Element, Q.Element)
 
@@ -79,7 +78,6 @@ public struct CombineLatestAsyncSequence<P: AsyncSequence, Q: AsyncSequence>: As
 // MARK: AsyncIteratorProtocol
 
 extension CombineLatestAsyncSequence: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     ///
     /// Continues to call `next()` on it's base iterator and iterator of
@@ -116,12 +114,9 @@ extension CombineLatestAsyncSequence: AsyncIteratorProtocol {
     }
 }
 
-
-
 // MARK: Combine latest
 
 extension AsyncSequence {
-
     /// Combine with an additional async sequence to produce a `AsyncCombineLatest2Sequence`.
     ///
     /// The combined sequence emits a tuple of the most-recent elements from each sequence

Asynchrone/Source/Sequences/CurrentElementAsyncSequence.swift

@@ -18,7 +18,6 @@
 /// // 4
 /// ```
 public actor CurrentElementAsyncSequence<Element>: AsyncSequence {
-
     /// The element wrapped by this async sequence, emitted as a new element whenever it changes.
     public private(set) var element: Element
 
@@ -72,8 +71,6 @@ public actor CurrentElementAsyncSequence<Element>: AsyncSequence {
     }
 }
 
-
-
 // MARK: Stream
 
 fileprivate struct _Stream<Element>: AsyncSequence {

Asynchrone/Source/Sequences/DebounceAsyncSequence.swift

@@ -147,8 +147,6 @@ extension DebounceAsyncSequence {
                     }
                 case .sleep:
                     self.resultTask = resultTask
-
-                    //
                     if let result = lastResult {
                         return try result._rethrowGet()
                     }

Asynchrone/Source/Sequences/DelayAsyncSequence.swift

@@ -1,6 +1,5 @@
 import Foundation
 
-
 /// Delays emission of all elements by the provided interval.
 ///
 /// ```swift
@@ -22,7 +21,6 @@ import Foundation
 /// // 2 - 1.5
 /// ```
 public struct DelayAsyncSequence<T: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = T.Element
 
@@ -59,24 +57,19 @@ public struct DelayAsyncSequence<T: AsyncSequence>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension DelayAsyncSequence: AsyncIteratorProtocol {
-
-    /// Produces the next element in the sequence.
-    /// - Returns: The next element or `nil` if the end of the sequence is reached.
-    public mutating func next() async throws -> Element? {
+    public mutating func next() async rethrows -> Element? {
         defer { self.lastEmission = Date() }
 
         let lastEmission = self.lastEmission ?? Date()
         let delay = self.interval - Date().timeIntervalSince(lastEmission)
         if delay > 0 {
-            try await Task.sleep(seconds: delay)
+            try? await Task.sleep(seconds: delay)
         }
 
         return try await self.iterator.next()
     }
 }
 
-
-
 // MARK: Delay
 
 extension AsyncSequence {

Asynchrone/Source/Sequences/Empty.swift

@@ -17,8 +17,6 @@
 /// // Finished
 /// ```
 public struct Empty<Element>: AsyncSequence {
-
-    // Private
     private let completeImmediately: Bool
 
     // MARK: Initialization
@@ -43,7 +41,6 @@ public struct Empty<Element>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension Empty: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     ///
     /// Because this is an empty sequence, this will always be nil.

Asynchrone/Source/Sequences/Fail.swift

@@ -17,10 +17,8 @@
 /// // Error!
 /// ```
 public struct Fail<Element, Failure>: AsyncSequence where Failure: Error {
-
-    // Private
-    let error: Failure
-    var hasThownError = false
+    private let error: Failure
+    private var hasThownError = false
 
     // MARK: Initialization
 
@@ -43,7 +41,6 @@ public struct Fail<Element, Failure>: AsyncSequence where Failure: Error {
 // MARK: AsyncIteratorProtocol
 
 extension Fail: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async throws -> Element? {

Asynchrone/Source/Sequences/Just.swift

@@ -11,10 +11,8 @@
 /// // 1
 /// ```
 public struct Just<Element>: AsyncSequence {
-
-    // Private
-    let element: Element
-    var emittedElement = false
+    private let element: Element
+    private var emittedElement = false
 
     // MARK: Initialization
 
@@ -37,7 +35,6 @@ public struct Just<Element>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension Just: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async -> Element? {

Asynchrone/Source/Sequences/Merge3AsyncSequence.swift

@@ -30,7 +30,6 @@
 /// // 4
 /// ```
 public struct Merge3AsyncSequence<T: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = T.Element
 

Asynchrone/Source/Sequences/MergeAsyncSequence.swift

@@ -36,7 +36,6 @@
 /// // 9
 /// ```
 public struct MergeAsyncSequence<T: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = T.Element
 

Asynchrone/Source/Sequences/PassthroughAsyncSequence.swift

@@ -17,8 +17,6 @@
 /// // 2
 /// ```
 public struct PassthroughAsyncSequence<Element>: AsyncSequence {
-
-    // Private
     private var stream: AsyncStream<Element>!
     private var continuation: AsyncStream<Element>.Continuation!
 

Asynchrone/Source/Sequences/RemoveDuplicatesAsyncSequence.swift

@@ -20,7 +20,6 @@
 /// // 3
 /// ```
 public struct RemoveDuplicatesAsyncSequence<Base: AsyncSequence>: AsyncSequence where Base.Element: Equatable {
-
     /// The kind of elements streamed.
     public typealias Element = Base.Element
 
@@ -61,7 +60,6 @@ public struct RemoveDuplicatesAsyncSequence<Base: AsyncSequence>: AsyncSequence
 // MARK: AsyncIteratorProtocol
 
 extension RemoveDuplicatesAsyncSequence: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     ///
     /// Continues to call `next()` on it's base iterator and discard the
@@ -90,12 +88,9 @@ extension RemoveDuplicatesAsyncSequence: AsyncIteratorProtocol {
     }
 }
 
-
-
 // MARK: Remove duplicates
 
 extension AsyncSequence where Element: Equatable {
-
     /// Emits only elements that don't match the previous element.
     /// - Returns: A `AsyncRemoveDuplicatesSequence` instance.
     public func removeDuplicates() -> RemoveDuplicatesAsyncSequence<Self> {

Asynchrone/Source/Sequences/ReplaceErrorAsyncSequence.swift

@@ -14,7 +14,6 @@
 /// // 0
 /// ```
 public struct ReplaceErrorAsyncSequence<Base: AsyncSequence>: AsyncSequence {
-
     /// The kind of elements streamed.
     public typealias Element = Base.Element
 
@@ -47,7 +46,6 @@ public struct ReplaceErrorAsyncSequence<Base: AsyncSequence>: AsyncSequence {
 // MARK: AsyncIteratorProtocol
 
 extension ReplaceErrorAsyncSequence: AsyncIteratorProtocol {
-
     /// Produces the next element in the sequence.
     /// - Returns: The next element or `nil` if the end of the sequence is reached.
     public mutating func next() async -> Element? {
@@ -59,12 +57,9 @@ extension ReplaceErrorAsyncSequence: AsyncIteratorProtocol {
     }
 }
 
-
-
 // MARK: Replace error
 
 extension AsyncSequence {
-
     /// Replaces any errors in the async sequence with the provided element.
     ///
     /// ```swift