Телеграмм чат группы rust

Size: a a a

Rust Async

2018 August 16

(на самом деле задача объединить работу двух независимых стримов;

можно конеш сделать через tokio::mpsc, но не хотелось бы экспозить этот API)

источник

15:59пожаловаться #1

pl 🦑 hk in Rust Async

чо значит объединить?

источник

16:04пожаловаться #2

мухожук in Rust Async

чтобы внутри Service работало два стрима (в частности, два TcpListener)

источник

16:09пожаловаться #3

Casual tears in Rust Async

все еще непонятно что тебе хочется, но скорее всего тебе нужен select https://docs.rs/futures/0.2.1/futures/stream/trait.StreamExt.html#method.select

источник

16:19пожаловаться #4

мухожук in Rust Async

да, выглядит надо
я почему-то нашёл future::select, но пропустил существование stream::select()

источник

16:22пожаловаться #5

мухожук in Rust Async

> все еще непонятно что тебе хочется,

хочется в рамках одного сервиса иметь 2 лисенера на разных адресах

источник

16:23пожаловаться #6

мухожук in Rust Async

(2 или больше)

источник

16:24пожаловаться #7

pl 🦑 hk in Rust Async

да, тогда селект

источник

16:25пожаловаться #8

pl 🦑 hk in Rust Async

я даже так где-то делал

источник

16:25пожаловаться #9

мухожук in Rust Async

а если N лисенеров?

источник

16:25пожаловаться #10

мухожук in Rust Async

писать SelectN?)

источник

16:26пожаловаться #11

pl 🦑 hk in Rust Async

let http = listener.incoming().map(|(s, sa)| Connection::Http(s, sa));
    let http2 = listener2.incoming().map(|(s, sa)| Connection::Http2(s, sa));

    info!("Ready to go");
    let server = http.select(http2).for_each(|conn| {
        match conn {
            Connection::Http(sock, addr) => {
                let s = s.clone();
                Http::new().bind_connection(&handle2, sock, addr, s);
            },
            Connection::Http2(sock, _addr) => {
                let http2_sc = httpbis::server_conf::ServerConf::new();
                let (_conn, future) = httpbis::server_conn::ServerConnection::new_plain_single_thread(&handle3, sock, http2_sc, grpc.clone());
                handle3.spawn(future.map_err(|e| error!("Error servicing http2 {}", e)));
            },
        }

        Ok(())
    });
    core.run(server).unwrap();