trixnity-client/de.connect2x.trixnity.client.media/InMemoryPlatformMedia

InMemoryPlatformMedia

interface InMemoryPlatformMedia : PlatformMedia

Functions

collect

abstract suspend fun collect(collector: FlowCollector<ByteArray>)

firstWithContent

suspend fun Flow<TimelineEvent?>.firstWithContent(): TimelineEvent

flatten

@JvmName(name = "flattenList")

inline fun <V> Flow<List<Flow<V?>>>.flatten(throttle: Duration = 200.milliseconds): Flow<List<V>>

fun <K, V> Flow<Map<K, Flow<V?>>>.flatten(throttle: Duration = 200.milliseconds): Flow<Map<K, V?>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

flattenNotNull

fun <K, V> Flow<Map<K, Flow<V?>>>.flattenNotNull(throttle: Duration = 200.milliseconds): Flow<Map<K, V>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

flattenValues

inline fun <K, V> Flow<Map<K, Flow<V?>>>.flattenValues(throttle: Duration = 200.milliseconds): Flow<List<V>>

A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

fun Flow<Map<RoomId, Flow<Room?>>>.flattenValues(throttle: Duration = 200.milliseconds, filterUpgradedRooms: Boolean = true): Flow<Set<Room>>

This collects all rooms, so when one changes, a new set gets emitted. A change of the outer flow results in new collect of the inner flows. Because this is an expensive operation, the outer flow is throttled by default.

getTemporaryFile

abstract suspend fun getTemporaryFile(): Result<PlatformMedia.TemporaryFile>

Returns a TemporaryFile that can be used to get a file representation of the media. This is stored unencrypted, so be careful to TemporaryFile.delete it, when not needed anymore.

toByteArray

abstract suspend fun toByteArray(coroutineScope: CoroutineScope? = null, expectedSize: Long? = null, maxSize: Long? = null): ByteArray?

Creates a ByteArray and stores it into a cache for re-use.

toFlowList

@JvmName(name = "toList")

fun Flow<Flow<TimelineEvent>>.toFlowList(maxSize: StateFlow<Int>, minSize: MutableStateFlow<Int> = MutableStateFlow(0)): Flow<List<Flow<TimelineEvent>>>

Converts a flow of timeline events into a flow of list of timeline events limited by maxSize.

@JvmName(name = "toListFromLatest")

fun Flow<Flow<Flow<TimelineEvent>>?>.toFlowList(maxSize: StateFlow<Int>, minSize: MutableStateFlow<Int> = MutableStateFlow(0)): Flow<List<Flow<TimelineEvent>>>

Converts a flow of flows of timeline event into a flow of list of timeline events limited by maxSize.

transformByteArrayFlow

abstract fun transformByteArrayFlow(transformer: (ByteArrayFlow) -> ByteArrayFlow): PlatformMedia