Merge pull request #46 from Orange-OpenSource/addUnmanageStream

add unmanage stream

Author: fsuc

OCast/Core/Application/ApplicationController.swift

@@ -199,6 +199,18 @@ public class ApplicationController: NSObject, DataStream, HttpProtocol {
             OCastLog.error("Unable to manage stream (\(stream.serviceId) because browser is nil")
         }
     }
+    
+    /// Used to release control over a user's specific stream.
+    ///
+    /// - Parameter stream: custom stream to be unmanaged
+    public func unmanage(stream: DataStream) {
+        if let browser = browser {
+            stream.dataSender = nil
+            browser.unregister(stream: stream)
+        } else {
+            OCastLog.error("Unable to unmanage stream (\(stream.serviceId) because browser is nil")
+        }
+    }
 
     // MARK: private methods
     private func startApplication(onSuccess: @escaping () -> Void, onError: @escaping (_ error: NSError?) -> Void) {

OCast/Core/Application/Media/Browser.swift

@@ -30,6 +30,10 @@ import Foundation
     ///
     /// - Parameter delegate: delegate
     func register(for delegate: EventDelegate)
+    /// unregister an event delegate
+    ///
+    /// - Parameter delegate: delegate
+    func unregister(for delegate: EventDelegate)
 }
 
 final class Browser: NSObject, EventDelegate {
@@ -45,6 +49,10 @@ final class Browser: NSObject, EventDelegate {
     func register(stream: DataStream) {
         streams.setObject(stream, forKey: stream.serviceId as NSString)
     }
+    
+    func unregister(stream: DataStream) {
+        streams.removeObject(forKey: stream.serviceId as NSString)
+    }
 
     func send(data: [String: Any], for service: String, onSuccess: @escaping ([String: Any]?) -> Void, onError: @escaping (NSError?) -> Void) {
 

OCast/ReferenceDriver/Driver/ReferenceDriver.swift

@@ -20,7 +20,7 @@ import Foundation
 /// Provides the Reference driver implementation.
 @objcMembers
 @objc open class ReferenceDriver: NSObject, Driver, LinkDelegate {
-    
+
     /// Success and error callbacks
     private struct Callback {
         let success: () -> Void
@@ -303,4 +303,8 @@ import Foundation
     public func register(for browser: EventDelegate) {
         self.browserEventDelegate = browser
     }
+    
+    public func unregister(for delegate: EventDelegate) {
+        browserEventDelegate = nil
+    }
 }

Podfile.lock

@@ -1,11 +1,11 @@
 PODS:
   - CocoaAsyncSocket (7.6.3)
-  - OCast (1.3.0):
-    - OCast/Core (= 1.3.0)
-    - OCast/ReferenceDriver (= 1.3.0)
-  - OCast/Core (1.3.0):
+  - OCast (1.4.1):
+    - OCast/Core (= 1.4.1)
+    - OCast/ReferenceDriver (= 1.4.1)
+  - OCast/Core (1.4.1):
     - CocoaAsyncSocket (= 7.6.3)
-  - OCast/ReferenceDriver (1.3.0):
+  - OCast/ReferenceDriver (1.4.1):
     - OCast/Core
   - Swifter (1.4.1)
 
@@ -32,7 +32,7 @@ CHECKOUT OPTIONS:
 
 SPEC CHECKSUMS:
   CocoaAsyncSocket: eafaa68a7e0ec99ead0a7b35015e0bf25d2c8987
-  OCast: 572339d7ce5f5b940174a5dd6b0acc83aeba5a98
+  OCast: f79be2a54a9bb76236eedef6fa991672b68b30c2
   Swifter: 62d14781d34600ffb6be99d350cf271be500600f
 
 PODFILE CHECKSUM: a802031d5c938076042ae8fd28af776322dfd580