Moved Observable's queue to subscriber

pedrommcarrasco · Jul 4, 2019 · bd9b294 · bd9b294
1 parent 4847d4c
commit bd9b294
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/Sucrose.podspec b/Sucrose.podspec
@@ -1,7 +1,7 @@
 Pod::Spec.new do |s|
   s.swift_version = "5.0"
   s.name         = "Sucrose"
-  s.version      = "3.6.0"
+  s.version      = "4.0.0"
   s.summary      = "🍬 Everyday sugar"
   s.description  = "Collection of handy methods & objects"
 

diff --git a/Sucrose/Objects/Observable.swift b/Sucrose/Objects/Observable.swift
@@ -24,16 +24,16 @@ public final class Observable<T> {
     private var observer: Observer?
     private var queue: DispatchQueue?
 
-    public init(_ value: T, dispachOn queue: DispatchQueue? = nil) {
+    public init(_ value: T) {
         self.value = value
-        self.queue = queue
     }
 }
 
 extension Observable {
 
-    public func subscribe(_ observer: Observer?) {
+    public func subscribe(on queue: DispatchQueue? = nil, _ observer: Observer?) {
         self.observer = observer
+        self.queue = queue
         observer?(value)
     }
 }