RecordingPacketConsumer

Kotlin |Java

@ExperimentalApi
public final class RecordingPacketConsumer<T extends Object> implements PacketConsumer

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

Summary

Public constructors
`<T extends Object> RecordingPacketConsumer()`

Public methods
`final @NonNull Function1<@NonNull T, Unit>`	`getOnQueue()`
`final @NonNull List<@NonNull PacketConsumer.Packet<@NonNull T>>`	`getQueuedPackets()`
`final @NonNull List<@NonNull T>`	`getQueuedPayloads()`
`void`	`queuePacket(@NonNull PacketConsumer.Packet<@NonNull T> packet)` Queues a `Packet` for processing, suspending the caller if the consumer is at capacity.
`void`	`release()` Releases all resources.
`final void`	`setOnQueue(@NonNull Function1<@NonNull T, Unit> onQueue)`

public <T extends Object> RecordingPacketConsumer()

public final @NonNull Function1<@NonNull T, Unit> getOnQueue()

public final @NonNull List<@NonNull PacketConsumer.Packet<@NonNull T>> getQueuedPackets()

public final @NonNull List<@NonNull T> getQueuedPayloads()

public void queuePacket(@NonNull PacketConsumer.Packet<@NonNull T> packet)

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
`@NonNull PacketConsumer.Packet<@NonNull T> packet`	The `Packet` to process.

public void release()

Releases all resources.

public final void setOnQueue(@NonNull Function1<@NonNull T, Unit> onQueue)