Skip to content

Commit

Permalink
squash!
Browse files Browse the repository at this point in the history
Signed-off-by: Nikola Hristov <[email protected]>
  • Loading branch information
NikolaRHristov committed Jul 10, 2024
1 parent cb5a5ca commit 77c61a0
Showing 1 changed file with 17 additions and 15 deletions.
32 changes: 17 additions & 15 deletions Source/Fn/Tauri.rs
Original file line number Diff line number Diff line change
Expand Up @@ -153,26 +153,28 @@ pub fn Fn() {
.build()
.expect("Cannot new_multi_thread.")
.block_on(async {
let Order = Arc::new(Mutex::new(
tokio_tungstenite::connect_async("ws://localhost:9999")
.await
.expect("Cannot connect_async.")
.0,
));
// TODO: UNCOMMENT THIS
// let Order = Arc::new(Mutex::new(
// tokio_tungstenite::connect_async("ws://localhost:9999")
// .await
// .expect("Cannot connect_async.")
// .0,
// ));

let Work = Arc::new(Work::Begin());
let (Approval, mut Receipt) = tokio::sync::mpsc::unbounded_channel();

// TODO: Auto-calc number of workers on the force
let Force: Vec<_> = (0..4)
.map(|_| {
tokio::spawn(Echo::Fn::Job::Fn(
Arc::new(Site { Order: Order.clone() }) as Arc<dyn Worker>,
Work.clone(),
Approval.clone(),
))
})
.collect();
// TODO: UNCOMMENT THIS
// let Force: Vec<_> = (0..4)
// .map(|_| {
// tokio::spawn(Echo::Fn::Job::Fn(
// Arc::new(Site { Order: Order.clone() }) as Arc<dyn Worker>,
// Work.clone(),
// Approval.clone(),
// ))
// })
// .collect();

let Builder = tauri::Builder::default();

Expand Down

0 comments on commit 77c61a0

Please sign in to comment.