Struct CdpSession 

pub struct CdpSession<T: ConnectionTransport> {
    pub session_id: Option<String>,
    /* private fields */
}

Fields

session_id: Option<String>

Implementations

impl<T: ConnectionTransport> CdpSession<T>

pub async fn ws_new( config: &ConnectionTransportConfig, ) -> CdpSession<WebsocketConnectionTransport>

pub async fn register_event_listener( &mut self, tx: UnboundedSender<EventResponse>, )

pub async fn send_and_get_receiver( &mut self, command: impl Into<CdpCommand>, ) -> Receiver<CdpCommandResponseState>

pub async fn send( &mut self, command: impl Into<CdpCommand>, ) -> Result<CommandResponse, CdpSessionSendError>

pub async fn close(&self)

Trait Implementations

impl<T: ConnectionTransport> CdpEventManagement for CdpSession<T>

fn get_events(&mut self) -> &mut Arc<Mutex<Vec<CdpEvent>>>

fn push_event(&mut self, event: CdpEvent)

fn add_event_handler<F, R>( &mut self, methods: impl IntoIterator<Item = impl Into<String>>, handler: F, ) -> String

where F: FnMut(EventResponse) -> R + Send + Sync + 'static, R: Future<Output = ()> + Send + 'static,

fn remove_cdp_event_handler(&mut self, id: &str)

fn event_dispatch( &mut self, ) -> impl Future<Output = (JoinHandle<()>, UnboundedSender<EventResponse>)>