Struct PolicyDecoder 

pub struct PolicyDecoder<D, R> { /* private fields */ }

A native decoder with one shared application resolver before every output presentation. No native frame is published on refusal, cancellation or an invalid/stale choice. The original frame is returned unchanged on success.

The resolver runs for every presentation, even within the same epoch: policy may inspect timing, and equal epochs do not prove equal interpretation. Reports keep the most recent decisions in a fixed bound.

All failures and caught unwinds are terminal and drop the native decoder, including its queued frames/references. reset is available only while the operation remains healthy; after failure construct a fresh operation. Frames previously returned remain valid through their own native owners.

Implementations

impl<D, R> PolicyDecoder<D, R>

pub fn new(decoder: D, resolver: R) -> Self

Wrap a native decoder and a built-in policy, application object or closure. Construction performs no decoding or policy decision. Native construction already happened; use Self::try_new to admit it before the factory runs.

pub fn with_policy_set(self, preset: PolicySet) -> Self

👎Deprecated:

Pass PolicySet or BoundPolicy as the operation policy argument

The built-in policy used when this resolver returns UsePreset. During migration, these requirements and the policy argument both apply. A bound policy supplies preferences in place of these.

pub fn report(&self) -> &OperationReport

Bounded decision history; also readable after terminal failure.

pub const fn is_failed(&self) -> bool

Whether this operation can no longer execute native work.

impl<D: VideoDecoder, R: OperationPolicy> PolicyDecoder<D, R>

pub fn try_new<E: StdError + Send + Sync + 'static>( factory: impl FnOnce() -> Result<D, E>, resolver: R, pulse: Option<&dyn Pulse>, ) -> Result<Self, Error>

Check mandatory workspace requirements before constructing the native decoder.

The factory is called once on admission, never on prior refusal/cancellation. Cancellation is checked again after successful construction; a cancelled decoder is dropped before it can be returned. The factory must poll during lengthy work itself; this boundary cannot preempt a synchronous constructor. This generic adapter has no qualified workspace bound, so any explicit workspace limit refuses even if large. Default policies permit construction. The factory must include native preparation; constructing a decoder first and moving it into this closure cannot put those earlier effects under admission. Frame interpretation and metadata decisions still happen at publication.

Trait Implementations

impl<D: VideoDecoder, R: OperationPolicy> VideoDecoder for PolicyDecoder<D, R>

type Error = Error

The implementation’s error.

fn configure( &mut self, config: &CodecConfig, pulse: Option<&dyn Pulse>, ) -> Result<(), SessionError<Error>>

Start a configuration epoch. Called before the first send and on every epoch change (new sequence header, new stsd entry).

fn send( &mut self, packet: &mut Packet, pulse: Option<&dyn Pulse>, ) -> Result<SendStatus, SessionError<Error>>

Offer one packet. Accepted takes its payload; ReceivePending leaves it intact for retry after receive.

fn receive( &mut self, pulse: Option<&dyn Pulse>, ) -> Result<Receive<Frame>, SessionError<Error>>

One frame at a time, in presentation order.

fn end_input(&mut self) -> Result<(), SessionError<Error>>

Declare end of input; idempotent. Then receive until EndOfStream.

fn reset(&mut self) -> Result<(), SessionError<Error>>

Discard queued input, output and references; keep configuration. Frames already returned stay valid.

fn stream_info(&self) -> Option<&VideoStreamInfo>

Facts about the stream seen so far.