Fix Property method ambiguity issues.

ReactiveKit.podspec

@@ -1,12 +1,12 @@
 Pod::Spec.new do |s|
   s.name             = "ReactiveKit"
-  s.version          = "2.0.0"
+  s.version          = "2.0.1"
   s.summary          = "A Swift Reactive Programming Framework"
   s.description      = "ReactiveKit is a collection of Swift frameworks for reactive and functional reactive programming."
   s.homepage         = "https://github.com/ReactiveKit/ReactiveKit"
   s.license          = 'MIT'
   s.author           = { "Srdan Rasic" => "[email protected]" }
-  s.source           = { :git => "https://github.com/ReactiveKit/ReactiveKit.git", :tag => "v2.0.0" }
+  s.source           = { :git => "https://github.com/ReactiveKit/ReactiveKit.git", :tag => "v2.0.1" }
 
   s.ios.deployment_target       = '8.0'
   s.osx.deployment_target       = '10.9'

ReactiveKit/Info.plist

@@ -15,7 +15,7 @@
 	<key>CFBundlePackageType</key>
 	<string>FMWK</string>
 	<key>CFBundleShortVersionString</key>
-	<string>2.0.0</string>
+	<string>2.0.1</string>
 	<key>CFBundleSignature</key>
 	<string>????</string>
 	<key>CFBundleVersion</key>

Sources/CollectionProperty.swift

@@ -130,7 +130,7 @@ public extension CollectionChangesetType where Collection.Index: Equatable {
   }
 }
 
-public protocol CollectionPropertyType: CollectionType, StreamType, PropertyType {
+public protocol CollectionPropertyType: CollectionType, StreamType, PropertyType, SubjectType {
   associatedtype Collection: CollectionType
   associatedtype Index = Collection.Index
   associatedtype Member = Collection.Generator.Element
@@ -202,6 +202,13 @@ public class CollectionProperty<C: CollectionType>: CollectionPropertyType {
     collection = changeset.collection
     subject.on(.Next(changeset))
   }
+
+  public func on(event: StreamEvent<CollectionChangeset<C>>) {
+    if let changeset = event.element {
+      collection = changeset.collection
+    }
+    subject.on(event)
+  }
 }
 
 public extension CollectionPropertyType {

Sources/Property.swift

@@ -65,6 +65,10 @@ public final class Property<T>: PropertyType, StreamType, SubjectType {
     _value = value
   }
 
+  public func silentUpdate(value: T) {
+    _value = value
+  }
+
   deinit {
     subject.completed()
   }

Sources/Subjects.swift

@@ -49,11 +49,13 @@ internal class ObserverRegister<E: EventType> {
   }
 }
 
-public protocol SubjectType: ObserverType, RawStreamType {
-  func on(event: Event)
+public protocol SubjectType: ObserverType, _StreamType {
 }
 
-public final class PublishSubject<E: EventType>: ObserverRegister<E>, SubjectType {
+public protocol RawSubjectType: ObserverType, RawStreamType {
+}
+
+public final class PublishSubject<E: EventType>: ObserverRegister<E>, RawSubjectType {
 
   private let lock = RecursiveLock(name: "ReactiveKit.PublishSubject")
   private var completed = false
@@ -77,7 +79,7 @@ public final class PublishSubject<E: EventType>: ObserverRegister<E>, SubjectTyp
   }
 }
 
-public final class ReplaySubject<E: EventType>: ObserverRegister<E>, SubjectType {
+public final class ReplaySubject<E: EventType>: ObserverRegister<E>, RawSubjectType {
 
   public let bufferSize: Int
   private var buffer: ArraySlice<E> = []
@@ -119,7 +121,7 @@ public final class ReplaySubject<E: EventType>: ObserverRegister<E>, SubjectType
   }
 }
 
-public final class ReplayOneSubject<E: EventType>: ObserverRegister<E>, SubjectType {
+public final class ReplayOneSubject<E: EventType>: ObserverRegister<E>, RawSubjectType {
 
   private var event: E? = nil
   private let lock = RecursiveLock(name: "ReactiveKit.ReplayOneSubject")
@@ -156,11 +158,11 @@ public final class ReplayOneSubject<E: EventType>: ObserverRegister<E>, SubjectT
   }
 }
 
-public final class AnySubject<E: EventType>: SubjectType {
+public final class AnySubject<E: EventType>: RawSubjectType {
   private let baseObserve: (E -> Void) -> Disposable
   private let baseOn: E -> Void
 
-  public init<S: SubjectType where S.Event == E>(base: S) {
+  public init<S: RawSubjectType where S.Event == E>(base: S) {
     baseObserve = base.observe
     baseOn = base.on
   }