Merge pull request #7 from RxSwiftCommunity/develop/emit

Support emit

Author: lm2343635

Example/RxBinding Example/Podfile.lock

@@ -0,0 +1,37 @@
+PODS:
+  - RxBinding (0.4):
+    - RxCocoa (< 6.0.0, >= 5.0.0)
+    - RxSwift (< 6.0.0, >= 5.0.0)
+  - RxCocoa (5.1.1):
+    - RxRelay (~> 5)
+    - RxSwift (~> 5)
+  - RxRelay (5.1.1):
+    - RxSwift (~> 5)
+  - RxSwift (5.1.1)
+  - SnapKit (5.0.1)
+
+DEPENDENCIES:
+  - RxBinding (from `../../`)
+  - SnapKit
+
+SPEC REPOS:
+  trunk:
+    - RxCocoa
+    - RxRelay
+    - RxSwift
+    - SnapKit
+
+EXTERNAL SOURCES:
+  RxBinding:
+    :path: "../../"
+
+SPEC CHECKSUMS:
+  RxBinding: da433c012633802a72c2a5bec8775b86f4cddeb8
+  RxCocoa: 32065309a38d29b5b0db858819b5bf9ef038b601
+  RxRelay: d77f7d771495f43c556cbc43eebd1bb54d01e8e9
+  RxSwift: 81470a2074fa8780320ea5fe4102807cb7118178
+  SnapKit: 97b92857e3df3a0c71833cce143274bf6ef8e5eb
+
+PODFILE CHECKSUM: 3dc791eedabb6208496ff999c24c1b9d6b616432
+
+COCOAPODS: 1.9.2

Example/RxBinding Example/RxBinding Example/AppDelegate.swift

@@ -21,4 +21,3 @@ class AppDelegate: UIResponder, UIApplicationDelegate {
     }
 
 }
-

RxBinding.podspec

@@ -8,7 +8,7 @@
 
 Pod::Spec.new do |s|
   s.name             = 'RxBinding'
-  s.version          = '0.3.1'
+  s.version          = '0.4'
   s.summary          = 'Simple data binding operators for RxSwift.'
 
 # This description is used to generate tags and improve search results.

Sources/RxBinding/Drive.swift

@@ -29,50 +29,50 @@ import RxCocoa
 infix operator ~> : DefaultPrecedence
 
 // Drive the observer, the relay or the binder.
-extension SharedSequenceConvertibleType where Self.SharingStrategy == RxCocoa.DriverSharingStrategy {
+extension SharedSequenceConvertibleType where SharingStrategy == DriverSharingStrategy {
 
-    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, Self.Element == O.Element {
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, Element == O.Element {
         return observable.drive(observer)
     }
 
-    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, O.Element == Self.Element? {
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, O.Element == Element? {
         return observable.drive(observer)
     }
 
-    public static func drive(observable: Self, relay: RxCocoa.BehaviorRelay<Self.Element>) -> Disposable {
+    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element>) -> Disposable {
         return observable.drive(relay)
     }
 
-    public static func drive(observable: Self, relay: RxCocoa.BehaviorRelay<Self.Element?>) -> Disposable {
+    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element?>) -> Disposable {
         return observable.drive(relay)
     }
 
-    public static func drive<R>(observable: Self, transformation: (RxSwift.Observable<Self.Element>) -> R) -> R {
+    public static func ~> <R>(observable: Self, transformation: (Observable<Self.Element>) -> R) -> R {
         return observable.drive(transformation)
     }
 
 }
 
 // Drive the array of observer, relay or binder.
-extension SharedSequenceConvertibleType where Self.SharingStrategy == RxCocoa.DriverSharingStrategy {
+extension SharedSequenceConvertibleType where SharingStrategy == DriverSharingStrategy {
 
-    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, Self.Element == O.Element {
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, Element == O.Element {
         return observers.map { observable.drive($0) }
     }
 
-    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, O.Element == Self.Element? {
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, O.Element == Element? {
         return observers.map { observable.drive($0) }
     }
 
-    public static func drive(observable: Self, relays: [RxCocoa.BehaviorRelay<Self.Element>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Element>]) -> [Disposable] {
         return relays.map { observable.drive($0) }
     }
 
-    public static func drive(observable: Self, relays: [RxCocoa.BehaviorRelay<Self.Element?>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Element?>]) -> [Disposable] {
         return relays.map { observable.drive($0) }
     }
 
-    public static func drive<R>(observable: Self, transformations: [(RxSwift.Observable<Self.Element>) -> R]) -> [R] {
+    public static func ~> <R>(observable: Self, transformations: [(Observable<Element>) -> R]) -> [R] {
         return transformations.map { observable.drive($0) }
     }
 

Sources/RxBinding/Emit.swift

@@ -0,0 +1,87 @@
+//
+//  Emit.swift
+//  RxBinding
+//
+//  Created by Meng Li on 05/25/2020.
+//  Copyright (c) 2020 MuShare. All rights reserved.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+// THE SOFTWARE.
+
+import RxSwift
+import RxCocoa
+
+infix operator ~> : DefaultPrecedence
+
+// Emit the observer, the relay or the binder.
+extension SharedSequenceConvertibleType where SharingStrategy == SignalSharingStrategy {
+    
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, Self.Element == O.Element {
+        return observable.emit(to: observer)
+    }
+    
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, O.Element == Self.Element? {
+        return observable.emit(to: observer)
+    }
+    
+    public static func ~> (observable: Self, relay: PublishRelay<Self.Element>) -> Disposable {
+        return observable.emit(to: relay)
+    }
+    
+    public static func ~> (observable: Self, relay: PublishRelay<Self.Element?>) -> Disposable {
+        return observable.emit(to: relay)
+    }
+    
+    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element>) -> Disposable {
+        return observable.emit(to: relay)
+    }
+    
+    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element?>) -> Disposable {
+        return observable.emit(to: relay)
+    }
+
+}
+
+// Emit the array of observer, relay or binder.
+extension SharedSequenceConvertibleType where SharingStrategy == SignalSharingStrategy {
+
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, Self.Element == O.Element {
+        return observers.map { observable.emit(to: $0) }
+    }
+
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, O.Element == Self.Element? {
+        return observers.map { observable.emit(to: $0) }
+    }
+    
+    public static func ~> (observable: Self, relays: [PublishRelay<Self.Element>]) -> [Disposable] {
+        return relays.map { observable.emit(to: $0) }
+    }
+    
+    public static func ~> (observable: Self, relays: [PublishRelay<Self.Element?>]) -> [Disposable] {
+        return relays.map { observable.emit(to: $0) }
+    }
+
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Self.Element>]) -> [Disposable] {
+        return relays.map { observable.emit(to: $0) }
+    }
+
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Self.Element?>]) -> [Disposable] {
+        return relays.map { observable.emit(to: $0) }
+    }
+
+}

Sources/RxBinding/OneWayBind.swift

@@ -31,27 +31,27 @@ infix operator ~> : DefaultPrecedence
 // Bind to the observer, the relay or the binder.
 extension ObservableType {
 
-    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O: ObserverType, O.Element == Self.Element {
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O: ObserverType, O.Element == Element {
         return observable.bind(to: observer)
     }
 
-    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, O.Element == Self.Element?  {
+    public static func ~> <O>(observable: Self, observer: O) -> Disposable where O : ObserverType, O.Element == Element?  {
         return observable.bind(to: observer)
     }
 
-    public static func ~> (observable: Self, relay: PublishRelay<Self.Element>) -> Disposable {
+    public static func ~> (observable: Self, relay: PublishRelay<Element>) -> Disposable {
         return observable.bind(to: relay)
     }
 
-    public static func ~> (observable: Self, relay: PublishRelay<Self.Element?>) -> Disposable {
+    public static func ~> (observable: Self, relay: PublishRelay<Element?>) -> Disposable {
         return observable.bind(to: relay)
     }
 
-    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element>) -> Disposable {
+    public static func ~> (observable: Self, relay: BehaviorRelay<Element>) -> Disposable {
         return observable.bind(to: relay)
     }
 
-    public static func ~> (observable: Self, relay: BehaviorRelay<Self.Element?>) -> Disposable {
+    public static func ~> (observable: Self, relay: BehaviorRelay<Element?>) -> Disposable {
         return observable.bind(to: relay)
     }
 
@@ -68,27 +68,27 @@ extension ObservableType {
 // Bind to the array of observer, relay or binder.
 extension ObservableType {
 
-    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O: ObserverType, O.Element == Self.Element {
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O: ObserverType, O.Element == Element {
         return observers.map { observable.bind(to: $0) }
     }
 
-    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, O.Element == Self.Element?  {
+    public static func ~> <O>(observable: Self, observers: [O]) -> [Disposable] where O : ObserverType, O.Element == Element?  {
         return observers.map { observable.bind(to: $0) }
     }
 
-    public static func ~> (observable: Self, relays: [PublishRelay<Self.Element>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [PublishRelay<Element>]) -> [Disposable] {
         return relays.map { observable.bind(to: $0) }
     }
 
-    public static func ~> (observable: Self, relays: [PublishRelay<Self.Element?>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [PublishRelay<Element?>]) -> [Disposable] {
         return relays.map { observable.bind(to: $0) }
     }
 
-    public static func ~> (observable: Self, relays: [BehaviorRelay<Self.Element>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Element>]) -> [Disposable] {
         return relays.map { observable.bind(to: $0) }
     }
 
-    public static func ~> (observable: Self, relays: [BehaviorRelay<Self.Element?>]) -> [Disposable] {
+    public static func ~> (observable: Self, relays: [BehaviorRelay<Element?>]) -> [Disposable] {
         return relays.map { observable.bind(to: $0) }
     }