Fixes #13. Delegates are now set on the correct delegate queue.

dsmurfin · Feb 1, 2021 · ad94c13 · ad94c13
1 parent ffbed4e
commit ad94c13
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/Sources/OTPKit/Components/Consumer.swift b/Sources/OTPKit/Components/Consumer.swift
@@ -121,7 +121,7 @@ final public class OTPConsumer: Component {
      
     */
     public func setConsumerDelegate(_ delegate: OTPConsumerDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.consumerDelegate = delegate
         }
     }
@@ -134,7 +134,7 @@ final public class OTPConsumer: Component {
      
     */
     public func setProtocolErrorDelegate(_ delegate: OTPComponentProtocolErrorDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.protocolErrorDelegate = delegate
         }
     }
@@ -147,7 +147,7 @@ final public class OTPConsumer: Component {
      
     */
     public func setDebugDelegate(_ delegate: OTPComponentDebugDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.debugDelegate = delegate
         }
     }

diff --git a/Sources/OTPKit/Components/Producer.swift b/Sources/OTPKit/Components/Producer.swift
@@ -140,7 +140,7 @@ final public class OTPProducer: Component {
      
     */
     public func setProducerDelegate(_ delegate: OTPProducerDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.producerDelegate = delegate
         }
     }
@@ -153,7 +153,7 @@ final public class OTPProducer: Component {
      
     */
     public func setProtocolErrorDelegate(_ delegate: OTPComponentProtocolErrorDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.protocolErrorDelegate = delegate
         }
     }
@@ -166,7 +166,7 @@ final public class OTPProducer: Component {
      
     */
     public func setDebugDelegate(_ delegate: OTPComponentDebugDelegate?) {
-        Self.queue.sync(flags: .barrier) {
+        delegateQueue.sync {
             self.debugDelegate = delegate
         }
     }