activity
Flow providing all activity events.
Samples
import com.millicast.Subscriber
import com.millicast.clients.stats.InboundRtpStream
import com.millicast.clients.stats.RemoteInboundRtpStream
import com.millicast.clients.stats.Stats
import com.millicast.devices.track.AudioTrack
import com.millicast.subscribers.state.ActivityStream
import com.millicast.subscribers.state.Layers
import io.dolby.samples.utils.Log
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.map
import kotlinx.coroutines.launch
fun main() {
//sampleStart
coroutineScope.launch {
// we can use the subscriber to be informed on new state regarding a stream
// and internal sourceId and their internal tracks
subscriber.activity.collect { activityStream ->
when (activityStream) {
is ActivityStream.Active -> reportActive(activityStream)
is ActivityStream.Inactive -> reportInactive(activityStream)
}
}
}
//sampleEnd
}