ビデオチャットアプリの作成

Kotlin

他のクライアント・ストリームへの加入

私たちはクライアントに次のことを望んでいる。 サブスクライブ セッション内の他のクライアントのストリームにアクセスする(または表示する)：

追加 subscriber プロパティをMainActivityクラスに追加します。 publisher プロパティ)：

private var subscriber: Subscriber? = null

SubscriberクラスはAndroid SDKで定義されている。これは、クライアントが他のクライアントによって公開されたストリームをサブスクライブ（表示）するために使用するオブジェクトを定義します。

の実装を変更する。 onStreamReceived(session, stream) メソッド(SessionListenerコールバックの1つ)に、他のクライアントのセッションストリームを購読するコードを含める：

override fun onStreamReceived(session: Session, stream: Stream) {
    Log.d(TAG, "onStreamReceived: New Stream Received ${stream.streamId} in session: ${session.sessionId}")

    if (subscriber == null) {
        val newSubscriber = Subscriber.Builder(this@MainActivity, stream).build().apply {
            renderer.setStyle(
                BaseVideoRenderer.STYLE_VIDEO_SCALE,
                BaseVideoRenderer.STYLE_VIDEO_FILL
            )
            setSubscriberListener(subscriberListener)
        }

        session.subscribe(newSubscriber)
        subscriber = newSubscriber
        subscriberView = newSubscriber.view
    }
}

Subscriber.Builder() 指定された Stream.
setSubscriberListener() ストリーム・イベントのリスナーをアタッチします。
session.subscribe() は、リモートストリームへのサブスクリプションを開始する。
subscriberView = newSubscriber.view は、ビデオ・ビューをレイアウトに配置します。

イベントを記録するには subscriberListener 以下の物件 sessionListener の MainActivity:

private val subscriberListener = object : SubscriberKit.SubscriberListener {
    override fun onConnected(subscriberKit: SubscriberKit) {
        Log.d(TAG, "onConnected: Subscriber connected. Stream: ${subscriberKit.stream?.streamId}")
    }

    override fun onDisconnected(subscriberKit: SubscriberKit) {
        Log.d(TAG, "onDisconnected: Subscriber disconnected. Stream: ${subscriberKit.stream?.streamId}")
    }

    override fun onError(subscriberKit: SubscriberKit, opentokError: OpentokError) {
        Log.e(TAG, "SubscriberKit onError: ${opentokError.message}")
    }
}

他のクライアントがセッションにストリームをパブリッシュすると、このメソッドが呼び出され、Streamオブジェクトが渡されます。StreamクラスはAndroid SDKで定義されており、セッション内のオーディオ・ビデオ・ストリームを表します。

このコードは、Android SDKで定義されているSubscriberクラスのインスタンスを初期化する。このコードでは Subscriber.Builder() コンストラクターは2つのパラメーターを取る：

このプロセスに関連付けられたAndroidアプリケーション・コンテキスト。
Streamオブジェクト（表示したいストリーム用）

について Session.subscribe(subscriber) メソッドは、受信したストリームを購読する。

の実装を変更する。 onStreamDropped(Session session, Stream stream) メソッド（SessionListenerコールバックのもう1つ）を呼び出します：

override fun onStreamDropped(session: Session, stream: Stream) {
    Log.i(TAG, "onStreamDropped: Stream dropped with ID: ${stream.streamId}")

    subscriber?.let {
        subscriberView = null
        subscriber = null
    }
}