opendht

KO | EN

gitlite — search

#hacktoberfest #react #typescript #golang #rust #deep-learning #docker #nodejs #java #windows #cli #vue #ios #open-source

(★ 9)

A Rust API for OpenDHT

opendht 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

A Rust API for [OpenDHT](https://github.com/savoirfairelinux/opendht).

#![feature(await_macro, async_await, futures_api)]

extern crate opendht;
    extern crate futures;
    #[macro_use] extern crate tokio;

use std::net::ToSocketAddrs;
    use tokio::prelude::*;

use opendht::OpenDht;

async fn run(dht: OpenDht) {
        println!("Bootstrapping...");
        let addrs: Vec<_> = "bootstrap.ring.cx:4222".to_socket_addrs().unwrap().collect();
        let f = dht.bootstrap(&addrs);
        await!(f).unwrap();

let key = &b"foo"[..];

println!("Storing...");
        let f = dht.put(key, &[9,9,9]);
        await!(f).unwrap();

let mut f = dht.get(key); // dht.listen(key) is also available

while let Some(item) = await!(f.next()) {
            println!("Found {:?}", item);
        }

dht.join();
        println!("Done: All threads joined.");
    }

fn main() {
        tokio::run_async(async {
            let dht = OpenDht::new(4222).unwrap();

let dht2 = dht.clone();
            tokio::spawn_async(async move {
                while let Some(next) = dht2.tick() {
                    let f = tokio::timer::Delay::new(next);
                    let _ = await!(f);
                }
            });

await!(run(dht));
        });
    }

opendht

opendht 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

opendht

opendht 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README