pocketstation 1.0.0

//! Session composition for the bounded polled-audio endpoint.
//!
//! The endpoint module owns the concrete driver and queue. Session owns only
//! declaration and registration against the canonical endpoint contracts.

use crate::endpoint::{PolledAudioEndpoint, POLLED_AUDIO_OPERATOR_ID};
use crate::graph::NodeTypeId;
use crate::session::{
    EndpointConfiguration, EndpointExtensionRegistrationError, EndpointHandle, OperatorId, Session,
    SessionEngineBuilder, SessionError, CONNECTOR_NODE_TYPE_ID,
};

impl Session {
    pub fn polled_audio(&self) -> Result<EndpointHandle, SessionError> {
        self.connector(
            OperatorId::new(POLLED_AUDIO_OPERATOR_ID),
            EndpointConfiguration::new(),
        )
    }
}

impl SessionEngineBuilder {
    pub fn register_polled_audio_endpoint(
        &mut self,
        endpoint: &PolledAudioEndpoint,
    ) -> Result<&mut Self, EndpointExtensionRegistrationError> {
        self.register_audio_endpoint_driver(
            OperatorId::new(POLLED_AUDIO_OPERATOR_ID),
            NodeTypeId::from(CONNECTOR_NODE_TYPE_ID),
            endpoint.factory(),
        )
    }
}