RecordingPacketConsumer

Kotlin |Java

@ExperimentalApi
class RecordingPacketConsumer<T : Any?> : PacketConsumer

A PacketConsumer implementation that holds a reference to all queued packets, and optionally releases the underlying frames.

Summary

Public constructors
`<T : Any?> RecordingPacketConsumer()`

Public functions
`open suspend Unit`	`queuePacket(packet: PacketConsumer.Packet<T>)` Queues a `Packet` for processing, suspending the caller if the consumer is at capacity.
`open suspend Unit`	`release()` Releases all resources.

Public properties
`(T) -> Unit`	`onQueue`
`List<PacketConsumer.Packet<T>>`	`queuedPackets`
`List<T>`	`queuedPayloads`

<T : Any?> RecordingPacketConsumer()

open suspend fun queuePacket(packet: PacketConsumer.Packet<T>): Unit

Queues a Packet for processing, suspending the caller if the consumer is at capacity.

Once this method returns, the ownership of the packet is transferred to this PacketConsumer, and the caller should not modify the packet.

Parameters
`packet: PacketConsumer.Packet<T>`	The `Packet` to process.

open suspend fun release(): Unit

Releases all resources.

var onQueue: (T) -> Unit

val queuedPackets: List<PacketConsumer.Packet<T>>

val queuedPayloads: List<T>