-
Notifications
You must be signed in to change notification settings - Fork 0
/
async-stream-eager.hir
27 lines (25 loc) · 1000 Bytes
/
async-stream-eager.hir
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
//! 1. Consider a stream in tokio.
//! If only the first item is polled, will we also iter on the subsequent ones?
//! 2. Consider N streams in tokio.
//! After they are merged, will we poll the first item of all of them?
#[prelude_import]
use std::prelude::rust_2018::*;
#[macro_use]
extern crate std;
use tokio;
use std::fs;
fn main() {
let body =
#[lang = "identity_future"](|mut _task_context:
#[lang = "ResumeTy"]|
{
{
::std::io::_print(<#[lang = "format_arguments"]>::new_v1(&["Hello, world!\n"],
&[]));
}
});
#[allow(clippy :: expect_used, clippy :: diverging_sub_expression)]
{
return tokio::runtime::Builder::new_multi_thread().enable_all().build().expect("Failed building the Runtime").block_on(body);
}
}