Library/com.lagradost.cloudstream3.utils/AtomicList

AtomicList

open class AtomicList<T>(delegate: List<T> = emptyList()) : List<T> , <ERROR CLASS> ERROR CLASS: Symbol not found for SynchronizedObject(source)

A thread-safe list backed by SynchronizedObject.

For iteration, wrap block in withLock to hold the lock for the duration: list.withLock { list.forEach { ... } }

Inheritors

AtomicMutableList

Constructors

AtomicList

constructor(delegate: List<T> = emptyList())

Properties

size

open override val size: Int

Functions

amap

suspend fun <A, B> List<A>.amap(f: suspend (A) -> B): List<B>

Short for "Asynchronous Map", runs on all values concurrently, this means that if you are not doing networking, you should use a regular map

amapIndexed

suspend fun <A, B> List<A>.amapIndexed(f: suspend (index: Int, A) -> B): List<B>

Short for "Asynchronous Map" with an Index, runs on all values concurrently, this means that if you are not doing networking, you should use a regular mapIndexed

apmap

fun <A, B> List<A>.~~apmap~~(f: suspend (A) -> B): List<B>

Short for "Asynchronous Parallel Map", but is not really parallel, only concurrent.

apmapIndexed

fun <A, B> List<A>.~~apmapIndexed~~(f: suspend (index: Int, A) -> B): List<B>

Short for "Asynchronous Parallel Map" with an Index, but is not really parallel, only concurrent.

contains

open operator override fun contains(element: T): Boolean

containsAll

open override fun containsAll(elements: Collection<T>): Boolean

distinctBy

fun distinctBy(selector: (T) -> Any?): AtomicList<T>

filter

fun filter(predicate: (T) -> Boolean): AtomicList<T>

get

open operator override fun get(index: Int): T

indexOf

open override fun indexOf(element: T): Int

isEmpty

open override fun isEmpty(): Boolean

iterator

open operator override fun iterator(): Iterator<T>

lastIndexOf

open override fun lastIndexOf(element: T): Int

listIterator

open override fun listIterator(): ListIterator<T>

open override fun listIterator(index: Int): ListIterator<T>

plus

operator fun plus(element: T): AtomicList<T>

operator fun plus(elements: Collection<T>): AtomicList<T>

subList

open override fun subList(fromIndex: Int, toIndex: Int): List<T>

toNewSearchResponseList

fun List<SearchResponse>.toNewSearchResponseList(hasNext: Boolean? = null): SearchResponseList

withLock

fun <R> withLock(block: () -> R): R