Skip to content

Commit ac7209a

Browse files
authored
Merge pull request HaishinKit#1524 from shogo4405/feature/deleteStream
implementation deleteStream.
2 parents 8dd8abd + 45d109d commit ac7209a

File tree

2 files changed

+14
-12
lines changed

2 files changed

+14
-12
lines changed

Examples/iOS/Preference.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@ struct Preference: Sendable {
22
// Temp
33
static nonisolated(unsafe) var `default` = Preference()
44

5-
var uri: String? = "rtmp://192.168.1.4/live"
5+
var uri: String? = "rtmp://192.168.1.6/live"
66
var streamName: String? = "live"
77
}

Sources/RTMP/RTMPStream.swift

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -501,18 +501,20 @@ open class RTMPStream: IOStream {
501501
readyState = .open
502502
if let fcPublishName {
503503
connection.call("FCUnpublish", responder: nil, arguments: fcPublishName)
504+
connection.call("deleteStream", responder: nil, arguments: id)
505+
} else {
506+
connection.doOutput(chunk: RTMPChunk(
507+
type: .zero,
508+
streamId: RTMPChunk.StreamID.command.rawValue,
509+
message: RTMPCommandMessage(
510+
streamId: id,
511+
transactionId: 0,
512+
objectEncoding: objectEncoding,
513+
commandName: "closeStream",
514+
commandObject: nil,
515+
arguments: []
516+
)))
504517
}
505-
connection.doOutput(chunk: RTMPChunk(
506-
type: .zero,
507-
streamId: RTMPChunk.StreamID.command.rawValue,
508-
message: RTMPCommandMessage(
509-
streamId: 0,
510-
transactionId: 0,
511-
objectEncoding: self.objectEncoding,
512-
commandName: "closeStream",
513-
commandObject: nil,
514-
arguments: [self.id]
515-
)))
516518
}
517519

518520
func doOutput(_ type: RTMPChunkType, chunkStreamId: UInt16, message: RTMPMessage) {

0 commit comments

Comments
 (0)