Release 1.2.1

Example/Podfile.lock

@@ -24,7 +24,7 @@ PODS:
   - RxCocoa (5.0.0):
     - RxRelay (~> 5)
     - RxSwift (~> 5)
-  - RxDataSources-Texture (1.2.0):
+  - RxDataSources-Texture (1.2.1):
     - Differentiator (~> 4.0)
     - RxCocoa (~> 5.0)
     - RxSwift (~> 5.0)
@@ -88,7 +88,7 @@ SPEC CHECKSUMS:
   PINRemoteImage: d6d51c5d2adda55f1ce30c96e850b6c4ebd2856a
   RxAlamofire: e7875a012aff55345672d0f70a2a9cd6aeb0f211
   RxCocoa: fcf32050ac00d801f34a7f71d5e8e7f23026dcd8
-  RxDataSources-Texture: f849e46f05f3f45353e1a117bfc52712851420e0
+  RxDataSources-Texture: eac7a5454555235619bfa7936c2db117e5bda309
   RxOptional: 9904e2219d59260c3c171273d475b2126de187e8
   RxRelay: 4f7409406a51a55cd88483f21ed898c234d60f18
   RxSwift: 8b0671caa829a763bbce7271095859121cbd895f

README.md

@@ -45,7 +45,7 @@ RxDataSources-Texture is available through [CocoaPods](https://cocoapods.org). T
 it, simply add the following line to your Podfile:
 
 ```ruby
-pod 'RxDataSources-Texture', '~> 1.2.0'
+pod 'RxDataSources-Texture', '~> 1.2.1'
 ```
 
 ## Author

RxDataSources-Texture.podspec

@@ -8,7 +8,7 @@
 
 Pod::Spec.new do |s|
     s.name             = 'RxDataSources-Texture'
-    s.version          = '1.2.0'
+    s.version          = '1.2.1'
     s.summary          = 'RxDataSources With Texture'
     s.description      = <<-DESC
     This is a collection of reactive data sources for ASTableNode and ASCollectionNode

RxDataSources-Texture/Classes/ASCollectionNode/ASCollectionNode+Rx.swift

@@ -29,7 +29,7 @@ extension Reactive where Base: ASCollectionNode {
         O: ObservableType>
         (dataSource: DataSource)
         -> (_ source: O)
-        -> Disposable where DataSource.Element == O.E {
+        -> Disposable where DataSource.Element == O.Element {
             return { source in
                 return source.subscribeProxyDataSource(ofObject: self.base, dataSource: dataSource, retainDataSource: true) { [weak collectionNode = self.base] (_: RxASCollectionDataSourceProxy, event) -> Void in
                     guard let collectionNode = collectionNode else {

RxDataSources-Texture/Classes/ASDelegateProxyType.swift

@@ -12,7 +12,7 @@ import RxSwift
 import RxCocoa
 
 extension ObservableType {
-    func subscribeProxyDataSource<DelegateProxy: DelegateProxyType>(ofObject object: DelegateProxy.ParentObject, dataSource: DelegateProxy.Delegate, retainDataSource: Bool, binding: @escaping (DelegateProxy, Event<E>) -> Void)
+    func subscribeProxyDataSource<DelegateProxy: DelegateProxyType>(ofObject object: DelegateProxy.ParentObject, dataSource: DelegateProxy.Delegate, retainDataSource: Bool, binding: @escaping (DelegateProxy, Event<Element>) -> Void)
         -> Disposable
         where DelegateProxy.ParentObject: ASDisplayNode
         , DelegateProxy.Delegate: AnyObject {
@@ -35,7 +35,7 @@ extension ObservableType {
                 // source can never end, otherwise it would release the subscriber, and deallocate the data source
                 .concat(Observable.never())
                 .takeUntil(object.rx.deallocated)
-                .subscribe { [weak object] (event: Event<E>) in
+                .subscribe { [weak object] (event: Event<Element>) in
 
                     if let object = object {
                         assert(proxy === DelegateProxy.currentDelegate(for: object), "Proxy changed from the time it was first set.\nOriginal: \(proxy)\nExisting: \(String(describing: DelegateProxy.currentDelegate(for: object)))")

RxDataSources-Texture/Classes/ASTableNode/ASTableNode+Rx.swift

@@ -37,7 +37,7 @@ extension Reactive where Base: ASTableNode {
         (dataSource: DataSource)
         -> (_ source: O)
         -> Disposable
-        where DataSource.Element == O.E {
+        where DataSource.Element == O.Element {
             return { source in
                 // Strong reference is needed because data source is in use until result subscription is disposed
                 return source.subscribeProxyDataSource(ofObject: self.base, dataSource: dataSource as ASTableDataSource, retainDataSource: true) { [weak tableNode = self.base] (_: RxASTableDataSourceProxy, event) -> Void in