Skip to content

Commit 527af4e

Browse files
committed
Fix stream closing
1 parent 7bc701e commit 527af4e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

livekit-android-sdk/src/main/java/io/livekit/android/room/datastream/incoming/IncomingDataStreamManager.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ class IncomingDataStreamManagerImpl @Inject constructor() : IncomingDataStreamMa
248248
val openMillis = SystemClock.elapsedRealtime() - descriptor.openTime
249249
LKLog.d { "Closed stream $id, (open for ${openMillis}ms" }
250250

251-
openStreams[id] = null
251+
openStreams.remove(id)
252252
}
253253
}
254254

@@ -270,7 +270,7 @@ class IncomingDataStreamManagerImpl @Inject constructor() : IncomingDataStreamMa
270270
val handler = byteStreamHandlers[info.topic]
271271
{ channel, identity ->
272272
if (handler == null) {
273-
LKLog.i { "Received byte stream for topic \"${info.topic}\", but no handler was found. Ignoring." }
273+
LKLog.w { "Received byte stream for topic \"${info.topic}\", but no handler was found. Ignoring." }
274274
} else {
275275
handler.invoke(ByteStreamReceiver(info, channel), identity)
276276
}

0 commit comments

Comments
 (0)