rupnp 0.1.3
“An asynchronous library for finding UPnP control points, performing actions on them and reading their service descriptions.”
imports http::Requestimports http::Uri
SHA-25640634524578b1913e17c8edb62bdc1c0647f81755ab702d60f767945b8eca0a1
MaleculeH₂(Cm₂F)
Evidence
26:10… sync fn from_url(url: Uri) -> Result<Self> {
27 let body = hyper::Client::new()
28 .get(url.clone())
29 .await?
30 .err_if_not_200()?
31 .into_body()
32 …
1use futures::prelude::*;
2use rupnp::{
3 http::Uri,
4 ssdp::{SearchTarget, URN},
5 DeviceSpec, Error, Service,
6};
7use std::{
8 fs,
9 path::{Path, PathBuf},
10 time::Duration,
11};
12use tokio::prelude::*;
13use tokio::task::{spawn, JoinHandle};
14
15#[tokio::main]
⋯7 lines
30:8… mut handles = Vec::new();
31
32 for device in devices {
33 print(&device, device.url(), 0, &pa …
67:19… sh(spawn(async move {
68 let mut svc_file = tokio::fs::File::create(path.join(&svc)).await?;
69
70 let mut buf = Vec::with_capacity(128);
71 write_service(&mut buf, service, url).await?;
72
73 svc_file.write_all(&buf).await?;
74 Ok(())
75 }));
⋯4 lines
132:21… dy.into())
133 .expect("infallible");
134 let doc = hyper::Client::new()
135 .request(request)
136 .await?
137 .err_if_not_200()?
138 .into_body()
139 …
Showing the top 5 files — 1 more file (3 regions) not shown.
No evidence locations were recorded for this file. Raw result