Add command send method; call create stream in a lock queue

shogo4405 · Mar 18, 2024 · b31b6d5 · b31b6d5
1 parent e2bee16
commit b31b6d5
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/Sources/RTMP/RTMPStream.swift b/Sources/RTMP/RTMPStream.swift
@@ -389,6 +389,11 @@ open class RTMPStream: IOStream {
         }
     }
 
+    /// Sends a command to the RTMP client or server.
+    public func send(commandName: String, arguments: Any?...) {
+        connection?.call(commandName, responder: nil, arguments: arguments)
+    }
+
     /// Creates flv metadata for a stream.
     open func makeMetaData() -> ASObject {
         var metadata: [String: Any] = [:]
@@ -548,7 +553,9 @@ open class RTMPStream: IOStream {
         switch code {
         case RTMPConnection.Code.connectSuccess.rawValue:
             readyState = .initialized
-            connection.createStream(self)
+            lockQueue.async {
+                connection.createStream(self)
+            }
         case RTMPStream.Code.playReset.rawValue:
             readyState = .play
         case RTMPStream.Code.playStart.rawValue: