use std::sync::mpsc::channel;
use std::sync::Arc;
use std::sync::RwLock;
use drive_server::types::Metadata;
use drive_server::drive_server::DriveServer;
fn main() -> Result<(), std::io::Error> {
// Source of truth
let lock = Arc::new(RwLock::new(vec![types::Metadata {
name: "fuji".to_string(),
extension: "jpg".to_string(),
name_extension: "fuji.jpg".to_string(),
hash: "b0e490e762234567eabc74fade854476fe692e320".to_string(),
size: 124093,
}]));
let c_lock = Arc::clone(&lock);
let (tx, rx) = channel();
thread::spawn(move || {
for received in rx {
let mut meta = lock.write().unwrap();
println!("File received: {:?}", received);
meta.push(received);
}
});
DriveServer::listen(&c_lock, tx).unwrap();
-
Notifications
You must be signed in to change notification settings - Fork 0
iankressin/hana-server
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published