Struct BtleplugTransport 

pub struct BtleplugTransport<P> { /* private fields */ }

An AsyncTransport adapter around a connected btleplug peripheral.

Device discovery and connection remain with the application. Construction discovers the peripheral’s services, validates the three required characteristics, and opens its notification stream.

The adapter implements AsyncTransport and, with the tokio feature, TokioTransport. See TokioTransport for the actor-compatible transport contract.

Implementations

impl<P: Peripheral> BtleplugTransport<P>

pub async fn new(peripheral: P) -> Result<Self, Error>

Creates an adapter around an already connected peripheral.

Call Peripheral::connect before this method. This method performs service discovery but does not establish the Bluetooth connection.

Examples

use btleplug::api::Peripheral;
use chessnut_move::transport::btleplug::{BtleplugTransport, Error};

BtleplugTransport::new(peripheral).await

Errors

Returns Error::Backend when service discovery or notification-stream creation fails. Returns Error::MissingCharacteristic when the connected peripheral does not expose a required Move characteristic.

pub const fn peripheral(&self) -> &P

Returns a shared reference to the wrapped peripheral.

pub fn peripheral_mut(&mut self) -> &mut P

Returns a mutable reference to the wrapped peripheral.

Direct operations can change connection or subscription state expected by the adapter.

pub fn into_peripheral(self) -> P

Consumes the adapter and returns the wrapped peripheral.

This method does not unsubscribe or disconnect the peripheral.

Trait Implementations

impl<P: Peripheral> AsyncTransport for BtleplugTransport<P>

type Error = Error

Error returned by Bluetooth or adapter operations.

async fn subscribe( &mut self, source: NotificationSource, ) -> Result<(), Self::Error>

Enables notifications for one protocol source.

async fn unsubscribe( &mut self, source: NotificationSource, ) -> Result<(), Self::Error>

Disables notifications for one protocol source.

async fn write_command(&mut self, command: &Command) -> Result<(), Self::Error>

Writes an encoded command using its required write kind.

async fn next_notification<'a>( &'a mut self, buffer: &'a mut [u8], ) -> Result<Notification<'a>, Self::Error>

Receives the next notification into the supplied buffer.

async fn close(&mut self) -> Result<(), Self::Error>

Closes transport-owned resources after subscriptions are disabled.

impl<P: Peripheral + 'static> TokioTransport for BtleplugTransport<P>

Available on crate feature tokio only.

type Error = Error

Error returned by Bluetooth or adapter operations.

async fn subscribe( &mut self, source: NotificationSource, ) -> Result<(), Self::Error>

Enables notifications for one protocol source.

async fn unsubscribe( &mut self, source: NotificationSource, ) -> Result<(), Self::Error>

Disables notifications for one protocol source.

async fn write_command(&mut self, command: &Command) -> Result<(), Self::Error>

Writes an encoded command using its required write kind.

async fn next_notification<'a>( &'a mut self, buffer: &'a mut [u8], ) -> Result<Notification<'a>, Self::Error>

Receives the next notification into the supplied buffer.

fn close(&mut self) -> impl Future<Output = Result<(), Self::Error>> + Send + '_

Closes transport-owned resources after subscriptions are disabled.