Merge branch 'improve/add-start-to-uispin'

README.md

@@ -314,6 +314,13 @@ Observable
     .disposed(by: self.disposeBag)
 ```
 
+or a shortest version:
+
+```swift
+self.uiSpin.start()
+// the underlying reactive stream will be disposed once uiSpin will be deinit
+```
+
 To send events in the loop, this is very straightforward, simply use the emit function:
 
 ```swift

Sources/Spin.Combine/CombineSwiftUISpin.swift

@@ -14,6 +14,7 @@ public final class CombineSwiftUISpin<State, Event>: CombineSpin<State, Event>,
     @Published
     public var state: State
     private let events = PassthroughSubject<Event, Never>()
+    private var disposeBag = [AnyCancellable]()
 
     public init(spin: CombineSpin<State, Event>) {
         self.state = spin.initialState
@@ -30,4 +31,8 @@ public final class CombineSwiftUISpin<State, Event>: CombineSpin<State, Event>,
     public func emit(_ event: Event) {
         self.events.send(event)
     }
+
+    public func start() {
+        AnyPublisher.start(spin: self).disposed(by: &self.disposeBag)
+    }
 }

Sources/Spin.Combine/CombineUISpin.swift

@@ -11,6 +11,7 @@ import SwiftUI
 
 @available(iOS 13.0, macOS 10.15, tvOS 13.0, watchOS 6.0, *)
 public final class CombineUISpin<State, Event>: CombineSpin<State, Event>, StateRenderer, EventEmitter {
+    private var disposeBag = [AnyCancellable]()
     private let events = PassthroughSubject<Event, Never>()
     private var externalRenderFunction: ((State) -> Void)?
     public var state: State {
@@ -38,4 +39,8 @@ public final class CombineUISpin<State, Event>: CombineSpin<State, Event>, State
     public func emit(_ event: Event) {
         self.events.send(event)
     }
+
+    public func start() {
+        AnyPublisher.start(spin: self).disposed(by: &self.disposeBag)
+    }
 }

Sources/Spin.ReactiveSwift/ReactiveSwiftUISpin.swift

@@ -14,6 +14,7 @@ public final class ReactiveSwiftUISpin<State, Event>: ReactiveSpin<State, Event>
     @Published
     public var state: State
     private let (eventsProducer, eventsObserver) = Signal<Event, Never>.pipe()
+    private let disposeBag = CompositeDisposable()
 
     public init(spin: ReactiveSpin<State, Event>) {
         self.state = spin.initialState
@@ -30,4 +31,8 @@ public final class ReactiveSwiftUISpin<State, Event>: ReactiveSpin<State, Event>
     public func emit(_ event: Event) {
         self.eventsObserver.send(value: event)
     }
+
+    public func start() {
+        SignalProducer.start(spin: self).disposed(by: self.disposeBag)
+    }
 }

Sources/Spin.ReactiveSwift/ReactiveUISpin.swift

@@ -9,6 +9,7 @@ import ReactiveSwift
 import Spin_Swift
 
 public final class ReactiveUISpin<State, Event>: ReactiveSpin<State, Event>, StateRenderer, EventEmitter {
+    private let disposeBag = CompositeDisposable()
     private let (eventsProducer, eventsObserver) = Signal<Event, Never>.pipe()
     private var externalRenderFunction: ((State) -> Void)?
     public var state: State {
@@ -36,4 +37,8 @@ public final class ReactiveUISpin<State, Event>: ReactiveSpin<State, Event>, Sta
     public func emit(_ event: Event) {
         self.eventsObserver.send(value: event)
     }
+
+    public func start() {
+        SignalProducer.start(spin: self).disposed(by: self.disposeBag)
+    }
 }

Sources/Spin.RxSwift/RxSwiftUISpin.swift

@@ -15,6 +15,7 @@ public final class RxSwiftUISpin<State, Event>: RxSpin<State, Event>, StateRende
     @Published
     public var state: State
     private let events = PublishRelay<Event>()
+    private let disposeBag = DisposeBag()
 
     public init(spin: RxSpin<State, Event>) {
         self.state = spin.initialState
@@ -31,4 +32,8 @@ public final class RxSwiftUISpin<State, Event>: RxSpin<State, Event>, StateRende
     public func emit(_ event: Event) {
         self.events.accept(event)
     }
+
+    public func start() {
+        Observable.start(spin: self).disposed(by: self.disposeBag)
+    }
 }

Sources/Spin.RxSwift/RxUISpin.swift

@@ -10,6 +10,7 @@ import RxSwift
 import Spin_Swift
 
 public final class RxUISpin<State, Event>: RxSpin<State, Event>, StateRenderer, EventEmitter {
+    private let disposeBag = DisposeBag()
     private let events = PublishRelay<Event>()
     private var externalRenderFunction: ((State) -> Void)?
     public var state: State {
@@ -37,4 +38,8 @@ public final class RxUISpin<State, Event>: RxSpin<State, Event>, StateRenderer,
     public func emit(_ event: Event) {
         self.events.accept(event)
     }
+
+    public func start() {
+        Observable.start(spin: self).disposed(by: self.disposeBag)
+    }
 }