ReferenceFull Library ReferenceNemo Voice AgentNemo Voice AgentPipecatProcessorsFrameworks

nemo_voice_agent.pipecat.processors.frameworks.rtvi

View as Markdown

Module Contents

Classes

NameDescription
RTVIObserverAn observer that processes RTVI frames and pushes them to the transport.

API

class nemo_voice_agent.pipecat.processors.frameworks.rtvi.RTVIObserver(
    rtvi: pipecat.processors.frameworks.rtvi.RTVIProcessor,
    args = (),
    kwargs = {}
)

Bases: _RTVIObserver

An observer that processes RTVI frames and pushes them to the transport.

TRANSPORT_OUTPUT_FRAMES
transport_output_seen
= set()
nemo_voice_agent.pipecat.processors.frameworks.rtvi.RTVIObserver.on_push_frame(
    data: pipecat.observers.base_observer.FramePushed
)
async

Process a frame being pushed through the pipeline.

Parameters:

data
FramePushed

Frame push event data containing source, frame, direction, and timestamp.

nemo_voice_agent.pipecat.processors.frameworks.rtvi.RTVIObserver.reset()

Reset the observer.