fix(wasm): std::time::Duration -> n0_future::time::Duration

Author: b5

src/actor.rs

@@ -4,15 +4,14 @@ use std::{
     collections::{hash_map, HashMap},
     num::NonZeroU64,
     sync::Arc,
-    time::Duration,
 };
 
 use anyhow::{anyhow, Context, Result};
 use bytes::Bytes;
 use futures_util::FutureExt;
 use iroh_blobs::Hash;
 use irpc::channel::mpsc;
-use n0_future::task::JoinSet;
+use n0_future::{task::JoinSet, time::Duration};
 use serde::{Deserialize, Serialize};
 use tokio::sync::oneshot;
 #[cfg(wasm_browser)]

src/net.rs

@@ -1,9 +1,9 @@
 //! Network implementation of the iroh-docs protocol
 
-use std::{future::Future, time::Duration};
+use std::future::Future;
 
 use iroh::{Endpoint, EndpointAddr, PublicKey};
-use n0_future::time::Instant;
+use n0_future::time::{Duration, Instant};
 use serde::{Deserialize, Serialize};
 use tracing::{debug, error_span, trace, Instrument};
 

src/sync.rs

@@ -11,13 +11,15 @@ use std::{
     fmt::Debug,
     ops::{Deref, DerefMut},
     sync::Arc,
-    time::Duration,
 };
 
 use bytes::{Bytes, BytesMut};
 use ed25519_dalek::{Signature, SignatureError};
 use iroh_blobs::Hash;
-use n0_future::{time::SystemTime, IterExt};
+use n0_future::{
+    time::{Duration, SystemTime},
+    IterExt,
+};
 use serde::{Deserialize, Serialize};
 
 pub use crate::heads::AuthorHeads;

tests/gc.rs

@@ -1,11 +1,12 @@
 #![allow(unused)]
 
-use std::{path::PathBuf, time::Duration};
+use std::path::PathBuf;
 
 use anyhow::Result;
 use bytes::Bytes;
 use futures_lite::StreamExt;
 use iroh_blobs::api::blobs::ImportMode;
+use n0_future::time::Duration;
 use rand::RngCore;
 use testdir::testdir;
 use util::Node;

tests/sync.rs

@@ -1,4 +1,4 @@
-use std::{collections::HashMap, future::Future, sync::Arc, time::Duration};
+use std::{collections::HashMap, future::Future, sync::Arc};
 
 use anyhow::{anyhow, bail, Context, Result};
 use bytes::Bytes;
@@ -15,7 +15,7 @@ use iroh_docs::{
     store::{DownloadPolicy, FilterKind, Query},
     AuthorId, ContentStatus, Entry,
 };
-use n0_future::time::Instant;
+use n0_future::time::{Duration, Instant};
 use rand::{CryptoRng, Rng, SeedableRng};
 #[cfg(feature = "fs-store")]
 use tempfile::tempdir;

tests/util.rs

@@ -67,7 +67,7 @@ pub struct Builder {
     use_n0_discovery: bool,
     storage: Storage,
     // node_discovery: Option<Box<dyn Discovery>>,
-    gc_interval: Option<std::time::Duration>,
+    gc_interval: Option<n0_future::time::Duration>,
     #[debug(skip)]
     register_gc_done_cb: Option<Box<dyn Fn() + Send + 'static>>,
     bind_random_port: bool,
@@ -165,7 +165,7 @@ impl Builder {
         self
     }
 
-    pub fn gc_interval(mut self, value: Option<std::time::Duration>) -> Self {
+    pub fn gc_interval(mut self, value: Option<n0_future::time::Duration>) -> Self {
         self.gc_interval = value;
         self
     }