Skip to content

Commit db7c322

Browse files
author
Devdutt Shenoi
committed
doc: update example with pkids
1 parent 8ad2223 commit db7c322

File tree

4 files changed

+52
-52
lines changed

4 files changed

+52
-52
lines changed

‎rumqttc/examples/ack_promise.rs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -28,38 +28,38 @@ async fn main() -> Result<(), Box<dyn Error>> {
2828
});
2929

3030
// Subscribe and wait for broker acknowledgement
31-
client
31+
let pkid = client
3232
.subscribe("hello/world", QoS::AtMostOnce)
3333
.await
3434
.unwrap()
3535
.await
3636
.unwrap();
37-
println!("Acknowledged Subscribe");
37+
println!("Acknowledged Subscribe({pkid})");
3838

3939
// Publish at all QoS levels and wait for broker acknowledgement
40-
client
40+
let pkid = client
4141
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
4242
.await
4343
.unwrap()
4444
.await
4545
.unwrap();
46-
println!("Acknowledged Pub(1)");
46+
println!("Acknowledged Pub({pkid})");
4747

48-
client
48+
let pkid = client
4949
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
5050
.await
5151
.unwrap()
5252
.await
5353
.unwrap();
54-
println!("Acknowledged Pub(2)");
54+
println!("Acknowledged Pub({pkid})");
5555

56-
client
56+
let pkid = client
5757
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
5858
.await
5959
.unwrap()
6060
.await
6161
.unwrap();
62-
println!("Acknowledged Pub(3)");
62+
println!("Acknowledged Pub({pkid})");
6363

6464
// Publish and spawn wait for notification
6565
let mut set = JoinSet::new();
@@ -68,22 +68,22 @@ async fn main() -> Result<(), Box<dyn Error>> {
6868
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
6969
.await
7070
.unwrap();
71-
set.spawn(async { future.await.map(|_| 1) });
71+
set.spawn(async { future.await });
7272

7373
let future = client
7474
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
7575
.await
7676
.unwrap();
77-
set.spawn(async { future.await.map(|_| 2) });
77+
set.spawn(async { future.await });
7878

7979
let future = client
8080
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
8181
.await
8282
.unwrap();
83-
set.spawn(async { future.await.map(|_| 3) });
83+
set.spawn(async { future.await });
8484

85-
while let Some(res) = set.join_next().await {
86-
println!("Acknowledged = {:?}", res?);
85+
while let Some(Ok(Ok(pkid))) = set.join_next().await {
86+
println!("Acknowledged Pub({pkid})");
8787
}
8888

8989
Ok(())

‎rumqttc/examples/ack_promise_sync.rs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -26,34 +26,34 @@ fn main() -> Result<(), Box<dyn Error>> {
2626
});
2727

2828
// Subscribe and wait for broker acknowledgement
29-
client
29+
let pkid = client
3030
.subscribe("hello/world", QoS::AtMostOnce)
3131
.unwrap()
3232
.blocking_recv()
3333
.unwrap();
34-
println!("Acknowledged Subscribe");
34+
println!("Acknowledged Subscribe({pkid})");
3535

3636
// Publish at all QoS levels and wait for broker acknowledgement
37-
client
37+
let pkid = client
3838
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
3939
.unwrap()
4040
.blocking_recv()
4141
.unwrap();
42-
println!("Acknowledged Pub(1)");
42+
println!("Acknowledged Pub({pkid})");
4343

44-
client
44+
let pkid = client
4545
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
4646
.unwrap()
4747
.blocking_recv()
4848
.unwrap();
49-
println!("Acknowledged Pub(2)");
49+
println!("Acknowledged Pub({pkid})");
5050

51-
client
51+
let pkid = client
5252
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
5353
.unwrap()
5454
.blocking_recv()
5555
.unwrap();
56-
println!("Acknowledged Pub(3)");
56+
println!("Acknowledged Pub({pkid})");
5757

5858
// Spawn threads for each publish, use channel to notify result
5959
let (tx, rx) = bounded(1);
@@ -63,7 +63,7 @@ fn main() -> Result<(), Box<dyn Error>> {
6363
.unwrap();
6464
let tx_clone = tx.clone();
6565
thread::spawn(move || {
66-
let res = future.blocking_recv().map(|_| 1);
66+
let res = future.blocking_recv();
6767
tx_clone.send(res).unwrap()
6868
});
6969

@@ -72,20 +72,20 @@ fn main() -> Result<(), Box<dyn Error>> {
7272
.unwrap();
7373
let tx_clone = tx.clone();
7474
thread::spawn(move || {
75-
let res = future.blocking_recv().map(|_| 2);
75+
let res = future.blocking_recv();
7676
tx_clone.send(res).unwrap()
7777
});
7878

7979
let future = client
8080
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
8181
.unwrap();
8282
thread::spawn(move || {
83-
let res = future.blocking_recv().map(|_| 3);
83+
let res = future.blocking_recv();
8484
tx.send(res).unwrap()
8585
});
8686

87-
while let Ok(res) = rx.recv() {
88-
println!("Acknowledged = {:?}", res?);
87+
while let Ok(Ok(pkid)) = rx.recv() {
88+
println!("Acknowledged Pub({:?})", pkid);
8989
}
9090

9191
Ok(())

‎rumqttc/examples/ack_promise_v5.rs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -28,38 +28,38 @@ async fn main() -> Result<(), Box<dyn Error>> {
2828
});
2929

3030
// Subscribe and wait for broker acknowledgement
31-
client
31+
let pkid = client
3232
.subscribe("hello/world", QoS::AtMostOnce)
3333
.await
3434
.unwrap()
3535
.await
3636
.unwrap();
37-
println!("Acknowledged Subscribe");
37+
println!("Acknowledged Subscribe({pkid})");
3838

3939
// Publish at all QoS levels and wait for broker acknowledgement
40-
client
40+
let pkid = client
4141
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
4242
.await
4343
.unwrap()
4444
.await
4545
.unwrap();
46-
println!("Acknowledged Pub(1)");
46+
println!("Acknowledged Pub({pkid})");
4747

48-
client
48+
let pkid = client
4949
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
5050
.await
5151
.unwrap()
5252
.await
5353
.unwrap();
54-
println!("Acknowledged Pub(2)");
54+
println!("Acknowledged Pub({pkid})");
5555

56-
client
56+
let pkid = client
5757
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
5858
.await
5959
.unwrap()
6060
.await
6161
.unwrap();
62-
println!("Acknowledged Pub(3)");
62+
println!("Acknowledged Pub({pkid})");
6363

6464
// Publish and spawn wait for notification
6565
let mut set = JoinSet::new();
@@ -68,22 +68,22 @@ async fn main() -> Result<(), Box<dyn Error>> {
6868
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
6969
.await
7070
.unwrap();
71-
set.spawn(async { future.await.map(|_| 1) });
71+
set.spawn(async { future.await });
7272

7373
let future = client
7474
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
7575
.await
7676
.unwrap();
77-
set.spawn(async { future.await.map(|_| 2) });
77+
set.spawn(async { future.await });
7878

7979
let future = client
8080
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
8181
.await
8282
.unwrap();
83-
set.spawn(async { future.await.map(|_| 3) });
83+
set.spawn(async { future.await });
8484

85-
while let Some(res) = set.join_next().await {
86-
println!("Acknowledged = {:?}", res?);
85+
while let Some(Ok(Ok(pkid))) = set.join_next().await {
86+
println!("Acknowledged Pub({pkid})");
8787
}
8888

8989
Ok(())

‎rumqttc/examples/ack_promise_v5_sync.rs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -26,34 +26,34 @@ fn main() -> Result<(), Box<dyn Error>> {
2626
});
2727

2828
// Subscribe and wait for broker acknowledgement
29-
client
29+
let pkid = client
3030
.subscribe("hello/world", QoS::AtMostOnce)
3131
.unwrap()
3232
.blocking_recv()
3333
.unwrap();
34-
println!("Acknowledged Subscribe");
34+
println!("Acknowledged Subscribe({pkid})");
3535

3636
// Publish at all QoS levels and wait for broker acknowledgement
37-
client
37+
let pkid = client
3838
.publish("hello/world", QoS::AtMostOnce, false, vec![1; 1])
3939
.unwrap()
4040
.blocking_recv()
4141
.unwrap();
42-
println!("Acknowledged Pub(1)");
42+
println!("Acknowledged Pub({pkid})");
4343

44-
client
44+
let pkid = client
4545
.publish("hello/world", QoS::AtLeastOnce, false, vec![1; 2])
4646
.unwrap()
4747
.blocking_recv()
4848
.unwrap();
49-
println!("Acknowledged Pub(2)");
49+
println!("Acknowledged Pub({pkid})");
5050

51-
client
51+
let pkid = client
5252
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
5353
.unwrap()
5454
.blocking_recv()
5555
.unwrap();
56-
println!("Acknowledged Pub(3)");
56+
println!("Acknowledged Pub({pkid})");
5757

5858
// Spawn threads for each publish, use channel to notify result
5959
let (tx, rx) = bounded(1);
@@ -63,7 +63,7 @@ fn main() -> Result<(), Box<dyn Error>> {
6363
.unwrap();
6464
let tx_clone = tx.clone();
6565
thread::spawn(move || {
66-
let res = future.blocking_recv().map(|_| 1);
66+
let res = future.blocking_recv();
6767
tx_clone.send(res).unwrap()
6868
});
6969

@@ -72,20 +72,20 @@ fn main() -> Result<(), Box<dyn Error>> {
7272
.unwrap();
7373
let tx_clone = tx.clone();
7474
thread::spawn(move || {
75-
let res = future.blocking_recv().map(|_| 2);
75+
let res = future.blocking_recv();
7676
tx_clone.send(res).unwrap()
7777
});
7878

7979
let future = client
8080
.publish("hello/world", QoS::ExactlyOnce, false, vec![1; 3])
8181
.unwrap();
8282
thread::spawn(move || {
83-
let res = future.blocking_recv().map(|_| 3);
83+
let res = future.blocking_recv();
8484
tx.send(res).unwrap()
8585
});
8686

87-
while let Ok(res) = rx.recv() {
88-
println!("Acknowledged = {:?}", res?);
87+
while let Ok(Ok(pkid)) = rx.recv() {
88+
println!("Acknowledged Pub({:?})", pkid);
8989
}
9090

9191
Ok(())

0 commit comments

Comments
 (0)