Struct BleShimTransport

Source

pub struct BleShimTransport { /* private fields */ }

Implementations§

Source §

impl BleShimTransport

Source

pub fn new(config: BleShimConfig) -> EmbeddedResult<Self>

Examples found in repository ?

examples/manual_tick_runtime.rs (line 10)

7fn main() {
8    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
9    let mut store = JournaledEmbeddedStore::new();
10    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");
11
12    transport.set_link_state(LinkState::Up);
13    runtime.tick(0, &mut transport, &mut store).expect("tick");
14    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
15    runtime.tick(1_000, &mut transport, &mut store).expect("tick");
16
17    while let Some(frame) = transport.take_outbound_wire() {
18        println!("outbound frame bytes={}", frame.len());
19    }
20}

Source

pub fn set_link_state(&mut self, state: LinkState)

Examples found in repository ?

examples/manual_tick_runtime.rs (line 12)

7fn main() {
8    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
9    let mut store = JournaledEmbeddedStore::new();
10    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");
11
12    transport.set_link_state(LinkState::Up);
13    runtime.tick(0, &mut transport, &mut store).expect("tick");
14    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
15    runtime.tick(1_000, &mut transport, &mut store).expect("tick");
16
17    while let Some(frame) = transport.take_outbound_wire() {
18        println!("outbound frame bytes={}", frame.len());
19    }
20}

Source

pub fn push_inbound_wire(&mut self, bytes: &[u8]) -> EmbeddedResult<()>

Source

pub fn drain_outbound_wire(&mut self) -> Vec<Vec<u8>>

Source

pub fn take_outbound_wire(&mut self) -> Option<Vec<u8>>

Examples found in repository ?

examples/manual_tick_runtime.rs (line 17)

7fn main() {
8    let mut runtime = EmbeddedNodeRuntime::new(RuntimeConfig::default()).expect("runtime");
9    let mut store = JournaledEmbeddedStore::new();
10    let mut transport = BleShimTransport::new(BleShimConfig::default()).expect("transport");
11
12    transport.set_link_state(LinkState::Up);
13    runtime.tick(0, &mut transport, &mut store).expect("tick");
14    runtime.queue_message([0x44; 16], b"hello from manual tick").expect("queue message");
15    runtime.tick(1_000, &mut transport, &mut store).expect("tick");
16
17    while let Some(frame) = transport.take_outbound_wire() {
18        println!("outbound frame bytes={}", frame.len());
19    }
20}