pub struct Channel {
pub def: ChannelDef,
pub ch_id: usize,
/* private fields */
}Expand description
Active runtime channel: manages CA lifecycle, monitor, and reconnect.
Fields§
§def: ChannelDef§ch_id: usizeImplementations§
Source§impl Channel
impl Channel
pub fn new(def: ChannelDef, ch_id: usize) -> Self
Sourcepub async fn connect(
&mut self,
ca_client: &CaClient,
macros: &HashMap<String, String>,
store: Arc<ChannelStore>,
dirty_flags: Vec<Arc<Vec<AtomicBool>>>,
ss_wakeups: Vec<Arc<Notify>>,
event_flags: Option<Arc<EventFlagSet>>,
)
pub async fn connect( &mut self, ca_client: &CaClient, macros: &HashMap<String, String>, store: Arc<ChannelStore>, dirty_flags: Vec<Arc<Vec<AtomicBool>>>, ss_wakeups: Vec<Arc<Notify>>, event_flags: Option<Arc<EventFlagSet>>, )
Connect to the CA server and optionally start monitoring.
pub fn is_connected(&self) -> bool
pub fn ca_channel(&self) -> Option<&CaChannel>
Auto Trait Implementations§
impl Freeze for Channel
impl !RefUnwindSafe for Channel
impl Send for Channel
impl Sync for Channel
impl Unpin for Channel
impl UnsafeUnpin for Channel
impl !UnwindSafe for Channel
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more