Struct PySourceAdapter 

pub struct PySourceAdapter { /* private fields */ }

Implementations

impl PySourceAdapter

pub fn new(obj: PyObject) -> Self

pub fn invoke_on_start(&self, notifier: PyNotifier)

If the user’s Python object has an on_start(notifier) method, call it.

Trait Implementations

impl Source for PySourceAdapter

fn claim<'a>( &'a self, name: &str, ) -> Pin<Box<dyn Future<Output = Option<PvInfo>> + Send + 'a>>

Check whether this source owns name and, if so, return its metadata.

fn get<'a>( &'a self, name: &str, ) -> Pin<Box<dyn Future<Output = Option<NtPayload>> + Send + 'a>>

Read the current value of a PV.

fn put<'a>( &'a self, name: &str, value: &DecodedValue, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, NtPayload)>, String>> + Send + 'a>>

Apply a PUT value to a PV.

fn subscribe<'a>( &'a self, _name: &str, ) -> Pin<Box<dyn Future<Output = Option<Receiver<NtPayload>>> + Send + 'a>>

Subscribe to value-change notifications on a PV.

fn rpc<'a>( &'a self, name: &str, args: &DecodedValue, ) -> Pin<Box<dyn Future<Output = Result<NtPayload, String>> + Send + 'a>>

Execute an RPC call on a channel.

fn names<'a>(&'a self) -> Pin<Box<dyn Future<Output = Vec<String>> + Send + 'a>>

List all PV names provided by this source.