Func

example.kt

fun getIceCandidate(): Flowable<IceCandidate> {
        return Flowable.create({ emitter ->
            socket.on("videoChat_iceCandidate_p2p", {
                val adapter = moshi.adapter<IceCandidate>(IceCandidate::class.java)
                try {
                    val result = adapter.fromJson(it.joinToString())
                    emitter.onNext(result!!)
                } catch (e: JsonDataException) {
                    e.printStackTrace()
                }
            })
        }, BackpressureStrategy.LATEST)
    }