leap_edge_rs
Utility library for connecting and receiving events from Leap Edge. Used for Channels and Pipe.
Installation
Add this to your Cargo.toml:
[dependencies]
leap_edge_rs = "0.1"
or if you want to add features:
[dependencies.leap_edge_rs]
version = "0.1"
default-features = false
features = ["rustls-tls-webpki-roots", "zlib"]
Usage
Subscribe to a channel
use leap_edge_rs::{LeapEdge, LeapOptions, leap::types::Event};
#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
let leap = LeapEdge::new(LeapOptions {
project: "my-project",
..Default::default()
}).await?;
leap.channel_subscribe("my-channel").await?;
while let Some(event) = leap.listen().await {
println!("{:?}", event);
}
}
Get all events:
use leap_edge_rs::{LeapEdge, LeapOptions};
#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
let leap = LeapEdge::new(LeapOptions {
project: "my-project",
..Default::default()
}).await?;
while let Some(event) = leap.listen().await {
println!("{:?}", event);
}
}
Get only messages or direct messages:
use leap_edge_rs::{LeapEdge, LeapOptions, leap::types::Event};
#[tokio::main]
async fn main() -> Result<(), std::io::Error> {
let leap = LeapEdge::new(LeapOptions {
project: "my-project",
..Default::default()
}).await?;
while let Some(event) = leap.listen().await {
match event {
Event::Message(message) | Event::DirectMessage(message) => println!("{:?}", message),
_ => {}
}
}
}
8 Sep 14, 2022
21 Nov 29, 2022
3 Oct 15, 2023
73 Jan 1, 2023
1.2k Jan 8, 2023
4 Aug 22, 2023
6 Jan 25, 2023
4 Mar 15, 2023
126 Dec 30, 2022
3 Apr 29, 2023
4 Jul 31, 2022
3 Dec 15, 2022
75 Apr 2, 2023
5 Jun 1, 2023
17 Dec 18, 2021
12 Nov 23, 2022
58 Oct 6, 2022
3 Sep 30, 2022
1 May 2, 2022