Skip to content

Commit

Permalink
naming tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
Brazol committed May 16, 2024
1 parent e9c94cf commit 00440c3
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions packages/stream_video/lib/src/call/session/call_session.dart
Original file line number Diff line number Diff line change
Expand Up @@ -119,15 +119,15 @@ class CallSession extends Disposable {
// Buffer sfu events until rtc manager is set
final bufferedStream = sfuWS.events
.asStream()
.takeWhile((element) => !_rtcManagerSubject!.hasValue)
.takeWhile((_) => !_rtcManagerSubject!.hasValue)
.buffer(_rtcManagerSubject!)
.expand((element) => element);
.expand((event) => event);

// Delay rest of the sfu events until rtc manager is set
final delayedStream = Rx.combineLatest2(
_rtcManagerSubject!,
sfuWS.events.asStream(),
(a, b) => b,
(_, event) => event,
).skip(1);

// Handle buffered events and then listen to sfu events as normal
Expand Down

0 comments on commit 00440c3

Please sign in to comment.