use std::rc::Rc;

use glommio::{LocalExecutor, spawn_local};

use glommio::{LocalExecutorBuilder, spawn_local};

async fn handle(stream: TcpStream, dict: Rc<DashSet<String, FxBuildHasher>>) {

async fn handle(stream: TcpStream, dict: &DashSet<String, FxBuildHasher>) {

    let ex = LocalExecutor::default();
    ex.run(async move {

    let dict = Box::new(DashSet::with_capacity_and_hasher(1<<16, FxBuildHasher::default()));
    let dict_ref = Box::leak(dict);
    LocalExecutorBuilder::default().spawn(move || async move {

        let dict = Rc::new(DashSet::with_capacity_and_hasher(1<<16, FxBuildHasher::default()));

            spawn_local(handle(stream, dict.clone())).detach();

            spawn_local(handle(stream, dict_ref)).detach();

    });

    }).unwrap();