正在显示
1 个修改的文件
包含
39 行增加
和
0 行删除
| @@ -444,16 +444,26 @@ constructor( | @@ -444,16 +444,26 @@ constructor( | ||
| 444 | 444 | ||
| 445 | 445 | ||
| 446 | //----------------------------------- RTCEngine.Listener ------------------------------------// | 446 | //----------------------------------- RTCEngine.Listener ------------------------------------// |
| 447 | + | ||
| 448 | + /** | ||
| 449 | + * @suppress | ||
| 450 | + */ | ||
| 447 | override fun onEngineConnected() { | 451 | override fun onEngineConnected() { |
| 448 | state = State.CONNECTED | 452 | state = State.CONNECTED |
| 449 | } | 453 | } |
| 450 | 454 | ||
| 455 | + /** | ||
| 456 | + * @suppress | ||
| 457 | + */ | ||
| 451 | override fun onEngineReconnected() { | 458 | override fun onEngineReconnected() { |
| 452 | state = State.CONNECTED | 459 | state = State.CONNECTED |
| 453 | listener?.onReconnected(this) | 460 | listener?.onReconnected(this) |
| 454 | eventBus.postEvent(RoomEvent.Reconnected(this), coroutineScope) | 461 | eventBus.postEvent(RoomEvent.Reconnected(this), coroutineScope) |
| 455 | } | 462 | } |
| 456 | 463 | ||
| 464 | + /** | ||
| 465 | + * @suppress | ||
| 466 | + */ | ||
| 457 | override fun onEngineReconnecting() { | 467 | override fun onEngineReconnecting() { |
| 458 | state = State.RECONNECTING | 468 | state = State.RECONNECTING |
| 459 | listener?.onReconnecting(this) | 469 | listener?.onReconnecting(this) |
| @@ -510,10 +520,16 @@ constructor( | @@ -510,10 +520,16 @@ constructor( | ||
| 510 | handleActiveSpeakersUpdate(speakers) | 520 | handleActiveSpeakersUpdate(speakers) |
| 511 | } | 521 | } |
| 512 | 522 | ||
| 523 | + /** | ||
| 524 | + * @suppress | ||
| 525 | + */ | ||
| 513 | override fun onRemoteMuteChanged(trackSid: String, muted: Boolean) { | 526 | override fun onRemoteMuteChanged(trackSid: String, muted: Boolean) { |
| 514 | localParticipant.onRemoteMuteChanged(trackSid, muted) | 527 | localParticipant.onRemoteMuteChanged(trackSid, muted) |
| 515 | } | 528 | } |
| 516 | 529 | ||
| 530 | + /** | ||
| 531 | + * @suppress | ||
| 532 | + */ | ||
| 517 | override fun onRoomUpdate(update: LivekitModels.Room) { | 533 | override fun onRoomUpdate(update: LivekitModels.Room) { |
| 518 | val oldMetadata = metadata | 534 | val oldMetadata = metadata |
| 519 | metadata = update.metadata | 535 | metadata = update.metadata |
| @@ -521,6 +537,9 @@ constructor( | @@ -521,6 +537,9 @@ constructor( | ||
| 521 | eventBus.postEvent(RoomEvent.RoomMetadataChanged(this, metadata, oldMetadata), coroutineScope) | 537 | eventBus.postEvent(RoomEvent.RoomMetadataChanged(this, metadata, oldMetadata), coroutineScope) |
| 522 | } | 538 | } |
| 523 | 539 | ||
| 540 | + /** | ||
| 541 | + * @suppress | ||
| 542 | + */ | ||
| 524 | override fun onConnectionQuality(updates: List<LivekitRtc.ConnectionQualityInfo>) { | 543 | override fun onConnectionQuality(updates: List<LivekitRtc.ConnectionQualityInfo>) { |
| 525 | updates.forEach { info -> | 544 | updates.forEach { info -> |
| 526 | val quality = ConnectionQuality.fromProto(info.quality) | 545 | val quality = ConnectionQuality.fromProto(info.quality) |
| @@ -550,6 +569,9 @@ constructor( | @@ -550,6 +569,9 @@ constructor( | ||
| 550 | participant.onDataReceived(data) | 569 | participant.onDataReceived(data) |
| 551 | } | 570 | } |
| 552 | 571 | ||
| 572 | + /** | ||
| 573 | + * @suppress | ||
| 574 | + */ | ||
| 553 | override fun onStreamStateUpdate(streamStates: List<LivekitRtc.StreamStateInfo>) { | 575 | override fun onStreamStateUpdate(streamStates: List<LivekitRtc.StreamStateInfo>) { |
| 554 | for (streamState in streamStates) { | 576 | for (streamState in streamStates) { |
| 555 | val participant = getParticipant(streamState.participantSid) ?: continue | 577 | val participant = getParticipant(streamState.participantSid) ?: continue |
| @@ -559,10 +581,16 @@ constructor( | @@ -559,10 +581,16 @@ constructor( | ||
| 559 | } | 581 | } |
| 560 | } | 582 | } |
| 561 | 583 | ||
| 584 | + /** | ||
| 585 | + * @suppress | ||
| 586 | + */ | ||
| 562 | override fun onSubscribedQualityUpdate(subscribedQualityUpdate: LivekitRtc.SubscribedQualityUpdate) { | 587 | override fun onSubscribedQualityUpdate(subscribedQualityUpdate: LivekitRtc.SubscribedQualityUpdate) { |
| 563 | localParticipant.handleSubscribedQualityUpdate(subscribedQualityUpdate) | 588 | localParticipant.handleSubscribedQualityUpdate(subscribedQualityUpdate) |
| 564 | } | 589 | } |
| 565 | 590 | ||
| 591 | + /** | ||
| 592 | + * @suppress | ||
| 593 | + */ | ||
| 566 | override fun onSubscriptionPermissionUpdate(subscriptionPermissionUpdate: LivekitRtc.SubscriptionPermissionUpdate) { | 594 | override fun onSubscriptionPermissionUpdate(subscriptionPermissionUpdate: LivekitRtc.SubscriptionPermissionUpdate) { |
| 567 | val participant = getParticipant(subscriptionPermissionUpdate.participantSid) as? RemoteParticipant ?: return | 595 | val participant = getParticipant(subscriptionPermissionUpdate.participantSid) as? RemoteParticipant ?: return |
| 568 | participant.onSubscriptionPermissionUpdate(subscriptionPermissionUpdate) | 596 | participant.onSubscriptionPermissionUpdate(subscriptionPermissionUpdate) |
| @@ -585,6 +613,9 @@ constructor( | @@ -585,6 +613,9 @@ constructor( | ||
| 585 | eventBus.tryPostEvent(RoomEvent.FailedToConnect(this, error)) | 613 | eventBus.tryPostEvent(RoomEvent.FailedToConnect(this, error)) |
| 586 | } | 614 | } |
| 587 | 615 | ||
| 616 | + /** | ||
| 617 | + * @suppress | ||
| 618 | + */ | ||
| 588 | override fun onSignalConnected(isReconnect: Boolean) { | 619 | override fun onSignalConnected(isReconnect: Boolean) { |
| 589 | if (state == State.RECONNECTING && isReconnect) { | 620 | if (state == State.RECONNECTING && isReconnect) { |
| 590 | // during reconnection, need to send sync state upon signal connection. | 621 | // during reconnection, need to send sync state upon signal connection. |
| @@ -592,10 +623,18 @@ constructor( | @@ -592,10 +623,18 @@ constructor( | ||
| 592 | } | 623 | } |
| 593 | } | 624 | } |
| 594 | 625 | ||
| 626 | + /** | ||
| 627 | + * @suppress | ||
| 628 | + */ | ||
| 595 | override fun onFullReconnecting() { | 629 | override fun onFullReconnecting() { |
| 596 | localParticipant.prepareForFullReconnect() | 630 | localParticipant.prepareForFullReconnect() |
| 631 | + remoteParticipants.keys.toMutableSet() // copy keys to avoid concurrent modifications. | ||
| 632 | + .forEach { sid -> handleParticipantDisconnect(sid) } | ||
| 597 | } | 633 | } |
| 598 | 634 | ||
| 635 | + /** | ||
| 636 | + * @suppress | ||
| 637 | + */ | ||
| 599 | override suspend fun onFullReconnect() { | 638 | override suspend fun onFullReconnect() { |
| 600 | localParticipant.republishTracks() | 639 | localParticipant.republishTracks() |
| 601 | } | 640 | } |
-
请 注册 或 登录 后发表评论