Heartbeat Sync

let isEnabled = try await client.presence.isEnabled()
if !isEnabled {
    try await client.presence.enable()
}

try await client.presence.startHeartbeat()

// Call when the user should no longer appear online.
client.presence.stopHeartbeat()

AmityCoreClient.presence().isEnabled()
    .flatMapCompletable { isEnabled ->
        val enableIfNeeded = if (isEnabled) {
            Completable.complete()
        } else {
            AmityCoreClient.presence().enable()
        }

        enableIfNeeded.andThen(AmityCoreClient.presence().startHeartbeat())
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({
        showSuccessMessage("Presence heartbeat started")
    }, { error ->
        showErrorMessage(error = error)
    })

// Call when the user should no longer appear online.
AmityCoreClient.presence().stopHeartbeat()

let roomPresence = AmityRoomPresenceRepository(roomId: roomId)

try await roomPresence.startHeartbeat()

// Call when the viewer leaves the room.
roomPresence.stopHeartbeat()

val roomPresence = AmityCoreClient.newRoomPresenceRepository().roomId(roomId)

roomPresence.startHeartbeat()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({
        showSuccessMessage("Room heartbeat started")
    }, { error ->
        showErrorMessage(error = error)
    })

// Call when the viewer leaves the room.
roomPresence.stopHeartbeat()

import { RoomPresenceRepository } from '@amityco/ts-sdk';

RoomPresenceRepository.startHeartbeat(roomId);

// Call when the viewer leaves the room.
RoomPresenceRepository.stopHeartbeat(roomId);