CapturingFrameProcessor.Factory


class CapturingFrameProcessor.Factory : FrameProcessor.Factory


A factory for CapturingFrameProcessor instances.

Summary

Public constructors

Factory(underlyingFactory: FrameProcessor.Factory!)

Creates a new instance.

Factory(
    underlyingFactory: FrameProcessor.Factory!,
    onQueueListener: Consumer<(Mutable)List<AsyncFrame!>!>?
)

Creates a new instance.

Public functions

CapturingFrameProcessor!
create(
    output: FrameWriter!,
    listenerExecutor: Executor!,
    listener: FrameProcessor.Listener!
)

Creates a FrameProcessor that sends frames to the given FrameWriter.

Public properties

volatile CapturingFrameProcessor?

Public constructors

Factory

Factory(underlyingFactory: FrameProcessor.Factory!)

Creates a new instance.

Parameters
underlyingFactory: FrameProcessor.Factory!

The factory that creates the underlying FrameProcessor.

Factory

Factory(
    underlyingFactory: FrameProcessor.Factory!,
    onQueueListener: Consumer<(Mutable)List<AsyncFrame!>!>?
)

Creates a new instance.

Parameters
underlyingFactory: FrameProcessor.Factory!

The factory that creates the underlying FrameProcessor.

onQueueListener: Consumer<(Mutable)List<AsyncFrame!>!>?

A listener that is invoked after each successful queue call.

Public functions

create

fun create(
    output: FrameWriter!,
    listenerExecutor: Executor!,
    listener: FrameProcessor.Listener!
): CapturingFrameProcessor!

Creates a FrameProcessor that sends frames to the given FrameWriter.

The created FrameProcessor does not close the passed in FrameWriter.

Parameters
output: FrameWriter!

The FrameWriter to which the FrameProcessor outputs.

listenerExecutor: Executor!

The Executor on which the listener is invoked.

listener: FrameProcessor.Listener!

A Listener to be invoked for FrameProcessor events.

Public properties

createdProcessor

volatile val createdProcessor: CapturingFrameProcessor?