ActivityCompat.requestPermissions(this,arrayOf(
    Manifest.permission.CAMERA,
    Manifest.permission.RECORD_AUDIO
), 1)

class MainActivity : AppCompatActivity(), IEventListener {

    private var connection: RTMPConnection? = null
    private var stream: RTMPStream? = null

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        ActivityCompat.requestPermissions(this,
                arrayOf(Manifest.permission.CAMERA,
                        Manifest.permission.RECORD_AUDIO),
                1)

        setContentView(R.layout.activity_main)

        connection = RTMPConnection()
        stream = RTMPStream(connection!!)
        stream?.attachCamera(Camera(android.hardware.Camera.open()))
        stream?.attachAudio(Audio())
        connection?.addEventListener("rtmpStatus", this)

        val button = findViewById(R.id.button) as Button
        button.setOnClickListener {
            connection?.connect("rtmp:https://192.168.11.15/live")
        }
    }

    override fun onStart() {
        super.onStart()
        val view1 = findViewById(R.id.camera) as CameraView
        view1.attachStream(stream!!)
    }

    override fun handleEvent(event: Event) {
        val data = EventUtils.toMap(event)
        val code = data["code"].toString()
        if (code == RTMPConnection.Codes.CONNECT_SUCCESS.rawValue) {
            Log.w(javaClass.name, "PUBLISH")
            stream!!.publish("live")
        }
    }
}