Struct BlockingConnection 

pub struct BlockingConnection<C> { /* private fields */ }

A Connection implementation that uses a threadpool to handle requests.

This type wraps around an existing x11rb Connection type, and makes it non-blocking by pushing all operations to a threadpool. This is good if, for instance, you have a Connection type that can’t trivially be integrated into a async runtime.

However, if you have the option of using a Connection type that is integrated into a real async reactor, you should use that instead.

Implementation

The blocking threadpool is used to handle all requests.

Implementations

impl<C: BlConnection + Send + Sync + 'static> BlockingConnection<C>

pub fn new(conn: Arc<C>) -> Self

Create a new BlockingConnection from an existing Connection.

pub fn get_ref(&self) -> &C

Get a reference to the underlying connection.

impl BlockingConnection<RustConnection>

pub async fn connect( display: Option<&str>, ) -> Result<(Self, usize), ConnectError>

Connect to the X11 server using this connection.

impl<S: Stream + Send + Sync + 'static> BlockingConnection<RustConnection<S>>

pub async fn connect_to_stream( stream: S, screen: usize, ) -> Result<Self, ConnectError>

Establish a connection over the given stream.

pub async fn connect_to_stream_with_auth_info( stream: S, screen: usize, auth_name: Vec<u8>, auth_data: Vec<u8>, ) -> Result<Self, ConnectError>

Establish a connection over the given stream using the given auth info

impl BlockingConnection<XCBConnection>

pub async fn connect( display: Option<&CStr>, ) -> Result<(Self, usize), ConnectError>

Connect to the X11 server using this connection.

Trait Implementations

impl<C: BlConnection + Send + Sync + 'static> Connection for BlockingConnection<C>

fn poll_for_raw_event_with_sequence( &self, ) -> Result<Option<RawEventAndSeqNumber<Self::Buf>>, ConnectionError>

Poll for a raw/unparsed event from the X11 server.

fn wait_for_raw_event_with_sequence( &self, ) -> Pin<Box<dyn Future<Output = Result<RawEventAndSeqNumber<Self::Buf>, ConnectionError>> + Send + '_>>

Wait for a raw/unparsed event from the X11 server.

fn generate_id( &self, ) -> Pin<Box<dyn Future<Output = Result<u32, ReplyOrIdError>> + Send + '_>>

Generate a new X11 identifier.

fn flush( &self, ) -> Pin<Box<dyn Future<Output = Result<(), ConnectionError>> + Send + '_>>

Flush the output buffer.

fn setup(&self) -> &Setup

Get the setup information of the connection.

fn wait_for_event( &self, ) -> Pin<Box<dyn Future<Output = Result<Event, ConnectionError>> + Send + '_>>

Wait for a new event from the X11 server.

fn wait_for_raw_event( &self, ) -> Pin<Box<dyn Future<Output = Result<Self::Buf, ConnectionError>> + Send + '_>>

Wait for a new event from the X11 server.

fn wait_for_event_with_sequence( &self, ) -> Pin<Box<dyn Future<Output = Result<EventAndSeqNumber, ConnectionError>> + Send + '_>>

Wait for a new event from the X11 server.

fn poll_for_event(&self) -> Result<Option<Event>, ConnectionError>

Poll for a new event from the X11 server.

fn poll_for_raw_event(&self) -> Result<Option<Self::Buf>, ConnectionError>

Poll for a raw/unparsed event from the X11 server.

fn poll_for_event_with_sequence( &self, ) -> Result<Option<EventAndSeqNumber>, ConnectionError>

Poll for a new event from the X11 server.

impl<C: Debug> Debug for BlockingConnection<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C: BlConnection + Send + Sync + 'static> RequestConnection for BlockingConnection<C>

type Buf = <C as RequestConnection>::Buf

Type used as buffer to store raw replies or events before they are parsed.

fn check_for_raw_error( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Buf>, ConnectionError>> + Send + '_>>

Check whether a request has errored.

fn discard_reply( &self, sequence: SequenceNumber, kind: RequestKind, mode: DiscardMode, )

The reply for this request shoiuld be discarded.

fn extension_information( &self, name: &'static str, ) -> Pin<Box<dyn Future<Output = Result<Option<ExtensionInformation>, ConnectionError>> + Send + '_>>

Get information about an extension.

fn prefetch_extension_information( &self, name: &'static str, ) -> Pin<Box<dyn Future<Output = Result<(), ConnectionError>> + Send + '_>>

Prefetch information about an extension.

fn maximum_request_bytes( &self, ) -> Pin<Box<dyn Future<Output = usize> + Send + '_>>

Get the maximum request length.

fn prefetch_maximum_request_bytes( &self, ) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Prefetches the maximum request length.

fn parse_error(&self, error: &[u8]) -> Result<X11Error, ParseError>

Parse a generic error.

fn parse_event(&self, event: &[u8]) -> Result<Event, ParseError>

Parse a generic event.

fn send_request_with_reply<'this, 'bufs, 'sl, 're, 'future, R>( &'this self, bufs: &'bufs [IoSlice<'sl>], fds: Vec<RawFdContainer>, ) -> Pin<Box<dyn Future<Output = Result<Cookie<'this, Self, R>, ConnectionError>> + Send + 'future>>

where R: TryParse + Send + 're, 'this: 'future, 'bufs: 'future, 'sl: 'future, 're: 'future,

Send a request with a reply to the server.

fn send_request_with_reply_with_fds<'this, 'bufs, 'sl, 're, 'future, R>( &'this self, bufs: &'bufs [IoSlice<'sl>], fds: Vec<RawFdContainer>, ) -> Pin<Box<dyn Future<Output = Result<CookieWithFds<'this, Self, R>, ConnectionError>> + Send + 'future>>

where R: TryParseFd + Send + 're, 'this: 'future, 'bufs: 'future, 'sl: 'future, 're: 'future,

Send a request with a reply containing file descriptors to the server.

fn send_request_without_reply<'this, 'bufs, 'sl, 'future>( &'this self, bufs: &'bufs [IoSlice<'sl>], fds: Vec<RawFdContainer>, ) -> Pin<Box<dyn Future<Output = Result<VoidCookie<'this, Self>, ConnectionError>> + Send + 'future>>

where 'this: 'future, 'bufs: 'future, 'sl: 'future,

Send a request without a reply to the server.

fn wait_for_reply( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Buf>, ConnectionError>> + Send + '_>>

Wait for the reply to a request.

fn wait_for_reply_or_raw_error( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<ReplyOrError<Self::Buf>, ConnectionError>> + Send + '_>>

Wait for the reply to a request.

fn wait_for_reply_with_fds_raw( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<ReplyOrError<BufWithFds<Self::Buf>, Self::Buf>, ConnectionError>> + Send + '_>>

Wait for the reply to a request with file descriptors.

fn send_trait_request_with_reply<'this, 'req, 'future, R>( &'this self, request: R, ) -> Pin<Box<dyn Future<Output = Result<Cookie<'this, Self, R::Reply>, ConnectionError>> + Send + 'future>>

where R: ReplyRequest + Send + 'req, R::Reply: Send, 'this: 'future, 'req: 'future,

Send a request with a reply to the server.

fn send_trait_request_with_reply_with_fds<'this, 'req, 'future, R>( &'this self, request: R, ) -> Pin<Box<dyn Future<Output = Result<CookieWithFds<'this, Self, R::Reply>, ConnectionError>> + Send + 'future>>

where R: ReplyFDsRequest + Send + 'req, R::Reply: Send, 'this: 'future, 'req: 'future,

Send a request with a reply containing file descriptors to the server.

fn send_trait_request_without_reply<'this, 'req, 'future, R>( &'this self, request: R, ) -> Pin<Box<dyn Future<Output = Result<VoidCookie<'this, Self>, ConnectionError>> + Send + 'future>>

where R: VoidRequest + Send + 'req, 'this: 'future, 'req: 'future,

Send a request without a reply to the server.

fn wait_for_reply_or_error( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<Self::Buf, ReplyError>> + Send + '_>>

Wait for the reply to a request.

fn wait_for_reply_with_fds( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<BufWithFds<Self::Buf>, ReplyError>> + Send + '_>>

Wait for the reply to a request with file descriptors.

fn check_for_error( &self, sequence: SequenceNumber, ) -> Pin<Box<dyn Future<Output = Result<(), ReplyError>> + Send + '_>>

Check whether a request has errored.