fix TcpSocket error

Author: pedroSG94

README.md

@@ -51,7 +51,7 @@ allprojects {
   }
 }
 dependencies {
-  implementation 'com.github.pedroSG94.rtmp-rtsp-stream-client-java:rtplibrary:2.1.8'
+  implementation 'com.github.pedroSG94.rtmp-rtsp-stream-client-java:rtplibrary:2.1.9'
 }
 
 ```

app/build.gradle

@@ -25,7 +25,7 @@ android {
 
 dependencies {
   implementation project(':rtplibrary')
-  implementation 'androidx.constraintlayout:constraintlayout:2.1.3'
+  implementation 'androidx.constraintlayout:constraintlayout:2.1.4'
   implementation 'com.google.android.material:material:1.6.0'
   implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlin_version"
 }

build.gradle

@@ -3,8 +3,8 @@
 buildscript {
   ext.kotlin_version = '1.6.21'
   ext.library_group = "com.github.pedroSG94"
-  ext.version_code = 218
-  ext.version_name = "2.1.8"
+  ext.version_code = 219
+  ext.version_name = "2.1.9"
 
   repositories {
     google()

rtmp/src/main/java/com/pedro/rtmp/utils/socket/TcpSocket.kt

@@ -17,10 +17,7 @@
 package com.pedro.rtmp.utils.socket
 
 import com.pedro.rtmp.utils.TLSSocketFactory
-import java.io.BufferedInputStream
-import java.io.IOException
-import java.io.InputStream
-import java.io.OutputStream
+import java.io.*
 import java.net.InetSocketAddress
 import java.net.Socket
 import java.net.SocketAddress
@@ -31,9 +28,9 @@ import java.security.GeneralSecurityException
  */
 class TcpSocket(private val host: String, private val port: Int, private val secured: Boolean): RtmpSocket() {
 
-  private lateinit var socket: Socket
-  private lateinit var input: BufferedInputStream
-  private lateinit var output: OutputStream
+  private var socket: Socket = Socket()
+  private var input: BufferedInputStream = BufferedInputStream(ByteArrayInputStream(byteArrayOf()))
+  private var output: OutputStream = ByteArrayOutputStream()
 
   override fun getOutStream(): OutputStream = output
 

rtmp/src/test/java/com/pedro/rtmp/utils/SocketTest.kt

@@ -0,0 +1,15 @@
+package com.pedro.rtmp.utils
+
+import com.pedro.rtmp.utils.socket.TcpSocket
+import org.junit.Test
+
+class SocketTest {
+
+    @Test
+    fun `check tcp socket error with socket not connected`() {
+        val socket = TcpSocket("127.0.0.1", 1935, false)
+        socket.getOutStream().write(0)
+        socket.getInputStream()
+        socket.close()
+    }
+}