正在显示
1 个修改的文件
包含
4 行增加
和
2 行删除
| @@ -229,13 +229,15 @@ constructor( | @@ -229,13 +229,15 @@ constructor( | ||
| 229 | run<Unit> { | 229 | run<Unit> { |
| 230 | val observer = CoroutineSdpObserver() | 230 | val observer = CoroutineSdpObserver() |
| 231 | subscriber.peerConnection.setLocalDescription(observer, answer) | 231 | subscriber.peerConnection.setLocalDescription(observer, answer) |
| 232 | - when (val outcome = observer.awaitCreate()) { | ||
| 233 | - is Either.Left -> client.sendAnswer(answer) | 232 | + when (val outcome = observer.awaitSet()) { |
| 234 | is Either.Right -> { | 233 | is Either.Right -> { |
| 235 | Timber.e { "error setting local description for answer: ${outcome.value}" } | 234 | Timber.e { "error setting local description for answer: ${outcome.value}" } |
| 235 | + return@launch | ||
| 236 | } | 236 | } |
| 237 | } | 237 | } |
| 238 | } | 238 | } |
| 239 | + | ||
| 240 | + client.sendAnswer(answer) | ||
| 239 | } | 241 | } |
| 240 | } | 242 | } |
| 241 | 243 |
-
请 注册 或 登录 后发表评论