@@ -107,12 +107,10 @@ use crate::mqtt::result_code::MqttError;
107107/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
108108/// .packet_id(42)
109109/// .entries(vec![
110- /// SubEntry::builder()
111- /// .topic_filter("sensors/temperature")
112- /// .unwrap()
113- /// .qos(Qos::AtLeastOnce)
114- /// .build()
115- /// .unwrap()
110+ /// SubEntry::new(
111+ /// "sensors/temperature",
112+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtLeastOnce)
113+ /// )?
116114/// ])
117115/// .build()
118116/// .unwrap();
@@ -125,18 +123,14 @@ use crate::mqtt::result_code::MqttError;
125123/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
126124/// .packet_id(123)
127125/// .entries(vec![
128- /// SubEntry::builder()
129- /// .topic_filter("home/+/temperature")
130- /// .unwrap()
131- /// .qos(Qos::AtMostOnce)
132- /// .build()
133- /// .unwrap(),
134- /// SubEntry::builder()
135- /// .topic_filter("alerts/#")
136- /// .unwrap()
137- /// .qos(Qos::ExactlyOnce)
138- /// .build()
139- /// .unwrap()
126+ /// SubEntry::new(
127+ /// "home/+/temperature",
128+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtMostOnce)
129+ /// )?,
130+ /// SubEntry::new(
131+ /// "alerts/#",
132+ /// mqtt::packet::SubOpts::new().set_qos(Qos::ExactlyOnce)
133+ /// )?
140134/// ])
141135/// .build()
142136/// .unwrap();
@@ -180,12 +174,10 @@ where
180174/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
181175/// .packet_id(1)
182176/// .entries(vec![
183- /// SubEntry::builder()
184- /// .topic_filter("my/topic")
185- /// .unwrap()
186- /// .qos(Qos::AtLeastOnce)
187- /// .build()
188- /// .unwrap()
177+ /// SubEntry::new(
178+ /// "my/topic",
179+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtLeastOnce)
180+ /// )?
189181/// ])
190182/// .build()
191183/// .unwrap();
@@ -216,12 +208,10 @@ where
216208 /// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
217209 /// .packet_id(42)
218210 /// .entries(vec![
219- /// SubEntry::builder()
220- /// .topic_filter("sensors/+")
221- /// .unwrap()
222- /// .qos(Qos::AtLeastOnce)
223- /// .build()
224- /// .unwrap()
211+ /// SubEntry::new(
212+ /// "sensors/+",
213+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtLeastOnce)
214+ /// )?
225215 /// ])
226216 /// .build()
227217 /// .unwrap();
@@ -272,12 +262,10 @@ where
272262 /// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
273263 /// .packet_id(123)
274264 /// .entries(vec![
275- /// SubEntry::builder()
276- /// .topic_filter("test/topic")
277- /// .unwrap()
278- /// .qos(Qos::AtMostOnce)
279- /// .build()
280- /// .unwrap()
265+ /// SubEntry::new(
266+ /// "test/topic",
267+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtMostOnce)
268+ /// )?
281269 /// ])
282270 /// .build()
283271 /// .unwrap();
@@ -375,12 +363,10 @@ where
375363 /// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
376364 /// .packet_id(1)
377365 /// .entries(vec![
378- /// SubEntry::builder()
379- /// .topic_filter("test")
380- /// .unwrap()
381- /// .qos(Qos::AtMostOnce)
382- /// .build()
383- /// .unwrap()
366+ /// SubEntry::new(
367+ /// "test",
368+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtMostOnce)
369+ /// )?
384370 /// ])
385371 /// .build()
386372 /// .unwrap();
@@ -416,12 +402,10 @@ where
416402 /// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
417403 /// .packet_id(1)
418404 /// .entries(vec![
419- /// SubEntry::builder()
420- /// .topic_filter("test/topic")
421- /// .unwrap()
422- /// .qos(Qos::AtLeastOnce)
423- /// .build()
424- /// .unwrap()
405+ /// SubEntry::new(
406+ /// "test/topic",
407+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtLeastOnce)
408+ /// )?
425409 /// ])
426410 /// .build()
427411 /// .unwrap();
@@ -552,12 +536,10 @@ where
552536 /// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
553537 /// .packet_id(1)
554538 /// .entries(vec![
555- /// SubEntry::builder()
556- /// .topic_filter("sensors/temperature")
557- /// .unwrap()
558- /// .qos(Qos::AtMostOnce)
559- /// .build()
560- /// .unwrap()
539+ /// SubEntry::new(
540+ /// "sensors/temperature",
541+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtMostOnce)
542+ /// )?
561543 /// ])
562544 /// .build()
563545 /// .unwrap();
@@ -599,12 +581,10 @@ where
599581/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
600582/// .packet_id(42)
601583/// .entries(vec![
602- /// SubEntry::builder()
603- /// .topic_filter("test/topic")
604- /// .unwrap()
605- /// .qos(Qos::AtLeastOnce)
606- /// .build()
607- /// .unwrap()
584+ /// SubEntry::new(
585+ /// "test/topic",
586+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtLeastOnce)
587+ /// )?
608588/// ])
609589/// .build()
610590/// .unwrap();
@@ -639,12 +619,10 @@ where
639619/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
640620/// .packet_id(1)
641621/// .entries(vec![
642- /// SubEntry::builder()
643- /// .topic_filter("debug/topic")
644- /// .unwrap()
645- /// .qos(Qos::AtMostOnce)
646- /// .build()
647- /// .unwrap()
622+ /// SubEntry::new(
623+ /// "debug/topic",
624+ /// mqtt::packet::SubOpts::new().set_qos(Qos::AtMostOnce)
625+ /// )?
648626/// ])
649627/// .build()
650628/// .unwrap();
@@ -682,12 +660,10 @@ where
682660/// let subscribe = mqtt::packet::v3_1_1::Subscribe::builder()
683661/// .packet_id(123)
684662/// .entries(vec![
685- /// SubEntry::builder()
686- /// .topic_filter("home/sensor")
687- /// .unwrap()
688- /// .qos(Qos::ExactlyOnce)
689- /// .build()
690- /// .unwrap()
663+ /// SubEntry::new(
664+ /// "home/sensor",
665+ /// mqtt::packet::SubOpts::new().set_qos(Qos::ExactlyOnce)
666+ /// )?
691667/// ])
692668/// .build()
693669/// .unwrap();
0 commit comments