diff options
| author | Matt Mastracci <matthew@mastracci.com> | 2023-08-23 17:03:05 -0600 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-08-23 17:03:05 -0600 |
| commit | b1ce2e41676ab5bc807a705b072986d9357fece5 (patch) | |
| tree | 18d9b7796221d6236c9e993602c56c769345b6ce /ext/kv | |
| parent | af1b794e53182dfe19cc675a107138263f08476c (diff) | |
fix(ext/web): add stream tests to detect v8slice split bug (#20253)
Co-authored-by: Bartek Iwańczuk <biwanczuk@gmail.com>
Diffstat (limited to 'ext/kv')
| -rw-r--r-- | ext/kv/remote.rs | 4 | ||||
| -rw-r--r-- | ext/kv/sqlite.rs | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/ext/kv/remote.rs b/ext/kv/remote.rs index 47528d15f..448a87b0d 100644 --- a/ext/kv/remote.rs +++ b/ext/kv/remote.rs @@ -24,7 +24,7 @@ use chrono::Utc; use deno_core::error::type_error; use deno_core::error::AnyError; use deno_core::futures::TryFutureExt; -use deno_core::task::JoinHandle; +use deno_core::unsync::JoinHandle; use deno_core::OpState; use prost::Message; use rand::Rng; @@ -357,7 +357,7 @@ impl MetadataRefresher { pub fn new(url: String, access_token: String) -> Self { let (tx, rx) = watch::channel(MetadataState::Pending); let handle = - deno_core::task::spawn(metadata_refresh_task(url, access_token, tx)); + deno_core::unsync::spawn(metadata_refresh_task(url, access_token, tx)); Self { handle, metadata_rx: rx, diff --git a/ext/kv/sqlite.rs b/ext/kv/sqlite.rs index bf2688920..f67154cb4 100644 --- a/ext/kv/sqlite.rs +++ b/ext/kv/sqlite.rs @@ -19,8 +19,8 @@ use deno_core::error::type_error; use deno_core::error::AnyError; use deno_core::futures; use deno_core::futures::FutureExt; -use deno_core::task::spawn; -use deno_core::task::spawn_blocking; +use deno_core::unsync::spawn; +use deno_core::unsync::spawn_blocking; use deno_core::AsyncRefCell; use deno_core::OpState; use rand::Rng; @@ -285,7 +285,7 @@ impl<P: SqliteDbHandlerPermissions> DatabaseHandler for SqliteDbHandler<P> { pub struct SqliteDb { conn: ProtectedConn, queue: OnceCell<SqliteQueue>, - expiration_watcher: deno_core::task::JoinHandle<()>, + expiration_watcher: deno_core::unsync::JoinHandle<()>, } impl Drop for SqliteDb { |