gistfile1.txt

    let res = stream.then(move |stream| {
        let stream = stream.expect("Error attaching to full node socket");
        client::post(&endpoint)
            .timeout(Duration::from_secs(8))
            .with_connection(Connection::from_stream(stream))
            .json(func_call)
            .unwrap()
            .send()
            .then(move |response| {
                trace!("Got response {:?}", response);
                match response {
                    Ok(res) => res.json().then(
                        move |val: Result<Web3Response, JsonPayloadError>| match val {
                            Ok(val) => {
                                DAOManager::from_registry().do_send(CacheCallback {
                                    id: target,
                                    dao_address: dao_address.clone(),
                                    response: val,
                                });
                                Ok(())
                            }
                            Err(e) => {
                                trace!("Got bad Web3Response {:?}", e);
                                return Ok(());
                            }
                        },
                    ),
                    Err(e) => {
                        warn!("Got error from full node {:?}", e);
                        future::ok.into()
                    }
                }
            })
    });
    Arbiter::spawn(res);