rtmp fail on read is configurable now

Author: pedroSG94

library/src/main/java/com/pedro/library/util/streamclient/RtmpStreamClient.kt

@@ -185,4 +185,11 @@ class RtmpStreamClient(
   fun setCustomAmfObject(amfObject: Map<String, Any>) {
     rtmpClient.setCustomAmfObject(amfObject)
   }
+
+  /**
+   * Should notify onConnectionFailed if read packet from the server failed
+   */
+  fun shouldFailOnRead(enabled: Boolean) {
+    rtmpClient.shouldFailOnRead = enabled
+  }
 }

rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt

@@ -108,6 +108,7 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
     get() = rtmpSender.bytesSend
   var socketType = SocketType.KTOR
   var socketTimeout = StreamSocket.DEFAULT_TIMEOUT
+  var shouldFailOnRead = false
 
   /**
    * Add certificates for TLS connection
@@ -317,7 +318,7 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
       }.exceptionOrNull()
       if (error != null && ConnectionFailed.parse(error.validMessage()) != ConnectionFailed.TIMEOUT) {
         scope.cancel()
-        connectChecker.onConnectionFailed(error.validMessage())
+        if (shouldFailOnRead) connectChecker.onConnectionFailed(error.validMessage())
       }
     }
   }