ntfy 0.9.1

Library for sending notifications over ntfy
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use futures_util::stream::StreamExt;
use ntfy::prelude::*;

#[tokio::main]
async fn main() -> Result<(), Error> {
    let subscriber = subscriber::builder("https://ntfy.sh")
        .credentials(Auth::credentials("username", "password")) // Add optional credentials
        .build_async()?; // Build subscriber

    // Subscribe to topic "test"
    let mut incoming_messages = subscriber.subscribe("mytopic").await?;

    // Listen
    while let Some(message) = incoming_messages.next().await {
        match message {
            Ok(message) => println!("Received message: {message:?}"),
            Err(error) => println!("Error: {error}"),
        }
    }

    Ok(())
}