Disconnecting and reconnecting from realtime channels

suspend fun getStream(gameId: String?): Flow<StreamSupabase> {
        val channel = createChannel(gameId)
        val channelFilter ="is_featured=eq.true"
        
        val changeFlow = channel.postgresChangeFlow<PostgresAction>("public") {
            table = "Stream"
            filter = channelFilter
        }.map {
            when (it) {
                is PostgresAction.Delete -> error("Delete should not be possible")
                is PostgresAction.Insert -> it.decodeRecord<StreamDto>().mapToEntity()
                is PostgresAction.Select -> error("Select should not be possible")
                is PostgresAction.Update -> it.decodeRecord<StreamDto>().mapToEntity()
            }
        }.catch {
            Log.d("StreamDatasource", "getFeaturedStream Error: $it")
        }
        channel.subscribe()
        return changeFlow
    }

DisposableEffect(null){
        onDispose {
            streamViewModel.stopListening(null)
        }
    }

suspend fun stopListening(gameId: String?) {
        val channel = createChannel(gameId)
        supabaseClient.realtime.removeChannel(channel)
    }