Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-07 08:56:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix runtime

Browse Source
This commit is contained in:
dignifiedquire
2023-07-14 16:32:35 +02:00
parent db8c3352ee
commit e24af97f3e
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/imex/transfer.rs
View File

@@ -39,6 +39,7 @@ use futures_lite::StreamExt;
use iroh::bytes::get::{fsm, Stats}; use iroh::bytes::get::{fsm, Stats};
use iroh::bytes::protocol::{AnyGetRequest, GetRequest, RequestToken}; use iroh::bytes::protocol::{AnyGetRequest, GetRequest, RequestToken};
use iroh::bytes::provider::Event as ProviderEvent; use iroh::bytes::provider::Event as ProviderEvent;
use iroh::bytes::util::runtime;
use iroh::collection::Collection; use iroh::collection::Collection;
use iroh::database::flat::DataSource; use iroh::database::flat::DataSource;
use iroh::dial::Ticket; use iroh::dial::Ticket;
@@ -189,9 +190,11 @@ impl BackupProvider {
let (db, hash) = iroh::database::flat::create_collection(files).await?; let (db, hash) = iroh::database::flat::create_collection(files).await?;
context.emit_event(SendProgress::CollectionCreated.into()); context.emit_event(SendProgress::CollectionCreated.into());
let auth_token_handler = StaticTokenAuthHandler::new(Some(token.clone())); let auth_token_handler = StaticTokenAuthHandler::new(Some(token.clone()));
let rt = runtime::Handle::from_currrent(1)?;
let provider = Node::builder(db) let provider = Node::builder(db)
.bind_addr((Ipv4Addr::UNSPECIFIED, 0).into()) .bind_addr((Ipv4Addr::UNSPECIFIED, 0).into())
.custom_auth_handler(Arc::new(auth_token_handler)) .custom_auth_handler(Arc::new(auth_token_handler))
.runtime(&rt)
.spawn() .spawn()
.await?; .await?;
context.emit_event(SendProgress::ProviderListening.into()); context.emit_event(SendProgress::ProviderListening.into());