Restarting stream causes "NetConnection.Connect.Closed" (v2.0.0-rc.0)

[abhinandan-chakraborty]

Hi again, I'm noticing issue with restarting stream after closing the stream. here is an example:
Basic Setup:

public class LivePageModel: ObservableObject {

  @Published var stream: RTMPStream?
  private let mixer = MediaMixer()
  private let connection = RTMPConnection()
  public var mthkView = MTHKView(frame: .zero)

  init() {
    initCamera()
    defer {
      Task.detached { @MainActor [self] in
        for await status in await connection.status {
          if status.code != "NetConnection.Connect.Closed" {
            continue
          }

          print("AAAAA: \(status)")  // <-- WHEN CONNECTION IS CLOSED
        }
      }
    }
  }

  //other methods

  public func initCamera() {
    Task { @MainActor in
      let session = AVAudioSession.sharedInstance()
      do {
        try session.setCategory(
          .playAndRecord, mode: .default, options: [.defaultToSpeaker, .allowBluetooth])
        try session.setActive(true)

        guard
          let videoDevice = AVCaptureDevice.default(
            .builtInDualWideCamera, for: .video, position: .back),
          let audioDevice = AVCaptureDevice.default(for: .audio)
        else {
          throw CameraLoadState.cameraNotFound
        }

        stream = RTMPStream(connection: connection)

        try await mixer.attachAudio(audioDevice)
        try await mixer.attachVideo(videoDevice)

        await mixer.addOutput(stream!)
        await stream!.addOutput(mthkView)

        //success
      } catch {
        //err
      }
    }
  }

}

Start Stream:

public class LivePageModel: ObservableObject {

  //other methods

  public func startStream() {
    Task {
      do {
        let result: RTMPResponse = try await connection.connect("rtmp://0.0.0.0:1935/stream")
        print("--> rtmp connect status: \(result)")
        let pubResult: RTMPResponse = try await stream.publish(
          "\(stream_id)?user=\(AuthModel.shared.getUserId())&pass=\(AuthModel.shared.getAccessToken())"
        )  //<-- passing user and pass as query parameter for `MediaMTX` server to handle authentication.
        print("--> rtmp publish status: \(pubResult)")

      } catch RTMPConnection.Error.requestFailed(let response) {
        print("--> rtmp connection error: \(String(describing: response.status))")
      } catch RTMPStream.Error.requestFailed(let response) {
        print("--> rtmp publish error: \(String(describing: response.status))")
      } catch {
        print("--> rtmp unknown error: \(error)")
      }
    }
  }

}

Stop Stream:

public class LivePageModel: ObservableObject {

  //other methods

  public func stopStream() {
    Task {
      do {
        try await connection.close()
        print("--> rtmp stop success")
      } catch {
        print("--> rtmp stop error: \(error)")
      }
    }
  }

}

When stopStream function is called it successfully print connection closed in the init method

AAAAA: RTMPStatus(code: "NetConnection.Connect.Closed", level: "status", description: "", data: nil)

But the problem is if now I try to call the startStream function again it immediately closes the connection after a second of connection success with the same log:

AAAAA: RTMPStatus(code: "NetConnection.Connect.Closed", level: "status", description: "", data: nil)

I also tried to stop stream with this inside stopStream function :

        let _ = try await stream.close()

but it still behave similarly as the connection.close(). Sometimes it works fine and sometimes it fails to connect during restart. Is there any way to avoid this problem?

[shogo4405]

I haven't encountered that case, so I'm not sure. I'd like to see the log when the connection is cut off for the second time. Please set it as follows and paste the values output in Xcode.

import Logboard

LBLogger.with(kHaishinKitIdentifier).level = .trace