heartbeat method

  1. @override
Stream<ChatCallEvents> heartbeat(
  1. ChatItemId id,
  2. ChatCallDeviceId deviceId
)
override

Subscribes to ChatCallEvents of an OngoingCall.

This subscription is mandatory to be created after executing start or join as represents a heartbeat indication of the authenticated MyUser's participation in an OngoingCall. Stopping or breaking this subscription without leaving the OngoingCall will end up by kicking the authenticated MyUser from this OngoingCall by timeout.

Implementation

@override
Stream<ChatCallEvents> heartbeat(ChatItemId id, ChatCallDeviceId deviceId) {
  Log.debug('heartbeat($id, $deviceId)', '$runtimeType');

  return _graphQlProvider.callEvents(id, deviceId).asyncExpand((
    event,
  ) async* {
    Log.trace('heartbeat($id): ${event.data}', '$runtimeType');

    final events =
        CallEvents$Subscription.fromJson(event.data!).chatCallEvents;

    if (events.$$typename == 'SubscriptionInitialized') {
      yield const ChatCallEventsInitialized();
    } else if (events.$$typename == 'ChatCall') {
      final call = events as CallEvents$Subscription$ChatCallEvents$ChatCall;
      yield ChatCallEventsChatCall(call.toModel(), call.ver);
    } else if (events.$$typename == 'ChatCallEventsVersioned') {
      final mixin = events as ChatCallEventsVersionedMixin;
      yield ChatCallEventsEvent(
        CallEventsVersioned(
          mixin.events.map((e) => _callEvent(e)).toList(),
          mixin.ver,
        ),
      );
    }
  });
}