Use Instant from web-time in more places (via ruma re-export)

web-time's Instant type is already used elsewhere in the project. It is
an alias for std's Instant type on most targets, but tries to call into
JavaScript on wasm32-unknown-unknown (assuming that the wasm blob is
used in from a browser context). Its Duration type is a plain re-export
of std's Duration, even on wasm32-unknown-unknown.
This commit is contained in:
Jonas Platte
2025-01-06 23:25:06 +01:00
committed by Damir Jelić
parent 70fb7899e6
commit 8e75a940f7
8 changed files with 21 additions and 26 deletions

View File

@@ -12,7 +12,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.
use std::{collections::HashMap, num::NonZeroUsize, sync::RwLock as StdRwLock, time::Instant};
use std::{collections::HashMap, num::NonZeroUsize, sync::RwLock as StdRwLock};
use async_trait::async_trait;
use matrix_sdk_common::{
@@ -20,7 +20,7 @@ use matrix_sdk_common::{
ring_buffer::RingBuffer,
store_locks::memory_store_helper::try_take_leased_lock,
};
use ruma::{MxcUri, OwnedMxcUri, RoomId};
use ruma::{time::Instant, MxcUri, OwnedMxcUri, RoomId};
use super::{EventCacheStore, EventCacheStoreError, Result};
use crate::{

View File

@@ -500,10 +500,9 @@ mod tests {
/// Some code that is shared by almost all `MemoryStore` implementations out
/// there.
pub mod memory_store_helper {
use std::{
collections::{hash_map::Entry, HashMap},
time::{Duration, Instant},
};
use std::collections::{hash_map::Entry, HashMap};
use ruma::time::{Duration, Instant};
pub fn try_take_leased_lock(
leases: &mut HashMap<String, (String, Instant)>,

View File

@@ -12,8 +12,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.
use std::time::Instant;
use ruma::time::Instant;
use tracing::{callsite::DefaultCallsite, Callsite as _};
/// A named RAII that will show on Drop how long its covered section took to

View File

@@ -16,14 +16,13 @@ use std::{
collections::{BTreeMap, HashMap, HashSet},
convert::Infallible,
sync::RwLock as StdRwLock,
time::Instant,
};
use async_trait::async_trait;
use matrix_sdk_common::store_locks::memory_store_helper::try_take_leased_lock;
use ruma::{
events::secret::request::SecretName, DeviceId, OwnedDeviceId, OwnedRoomId, OwnedTransactionId,
OwnedUserId, RoomId, TransactionId, UserId,
events::secret::request::SecretName, time::Instant, DeviceId, OwnedDeviceId, OwnedRoomId,
OwnedTransactionId, OwnedUserId, RoomId, TransactionId, UserId,
};
use tokio::sync::RwLock;
use tracing::warn;

View File

@@ -14,14 +14,11 @@
//! States and actions for the `RoomList` state machine.
use std::{
future::ready,
sync::Mutex,
time::{Duration, Instant},
};
use std::{future::ready, sync::Mutex};
use eyeball::{SharedObservable, Subscriber};
use matrix_sdk::{sliding_sync::Range, SlidingSync, SlidingSyncMode};
use ruma::time::{Duration, Instant};
use super::Error;

View File

@@ -21,13 +21,15 @@
use std::{
collections::HashMap,
sync::{Arc, Mutex},
time::{Duration, Instant},
};
use growable_bloom_filter::{GrowableBloom, GrowableBloomBuilder};
use matrix_sdk::{crypto::types::events::UtdCause, Client};
use matrix_sdk_base::{StateStoreDataKey, StateStoreDataValue, StoreError};
use ruma::{EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedServerName, UserId};
use ruma::{
time::{Duration, Instant},
EventId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedServerName, UserId,
};
use tokio::{
spawn,
sync::{Mutex as AsyncMutex, MutexGuard},

View File

@@ -1,7 +1,4 @@
use std::{
ops::Not,
time::{Duration, Instant},
};
use std::ops::Not;
use assert_matches::assert_matches;
use eyeball_im::VectorDiff;
@@ -27,8 +24,11 @@ use matrix_sdk_ui::{
RoomListService,
};
use ruma::{
api::client::room::create_room::v3::Request as CreateRoomRequest, event_id,
events::room::message::RoomMessageEventContent, mxc_uri, room_id,
api::client::room::create_room::v3::Request as CreateRoomRequest,
event_id,
events::room::message::RoomMessageEventContent,
mxc_uri, room_id,
time::{Duration, Instant},
};
use serde_json::json;
use stream_assert::{assert_next_matches, assert_pending};

View File

@@ -15,9 +15,8 @@
//! A wrapper around a hash map that tracks pending requests and makes sure
//! that expired requests are removed.
use std::time::{Duration, Instant};
use indexmap::{map::Entry, IndexMap};
use ruma::time::{Duration, Instant};
use tracing::warn;
use uuid::Uuid;