1 1| |// compile-flags: --edition=2018
2 2| |#![feature(no_coverage)]
4 4| |macro_rules! bail {
5 5| | ($msg:literal $(,)?) => {
6 6| | if $msg.len() > 0 {
7 7| | println!("no msg");
11 11| | return Err(String::from($msg));
15 15| |macro_rules! on_error {
16 16| | ($value:expr, $error_message:expr) => {
17 17| | $value.or_else(|e| { // FIXME(85000): no coverage in closure macros
18 18| | let message = format!($error_message, e);
19 19| | if message.len() > 0 {
20 20| | println!("{}", message);
21 21| | Ok(String::from("ok"))
29 29| 1|fn load_configuration_files() -> Result<String, String> {
30 30| 1| Ok(String::from("config"))
33 33| 1|pub async fn test() -> Result<(), String> {
34 34| 1| println!("Starting service");
35 35| 1| let config = on_error!(load_configuration_files(), "Error loading configs: {}")?;
38 37| 1| let startup_delay_duration = String::from("arg");
39 38| 1| let _ = (config, startup_delay_duration);
45 44| | executor::block_on(test());
52 51| | task::{Context, Poll, RawWaker, RawWakerVTable, Waker},
56 55| | pub fn block_on<F: Future>(mut future: F) -> F::Output {
57 56| | let mut future = unsafe { Pin::new_unchecked(&mut future) };
58 57| | use std::hint::unreachable_unchecked;
59 58| | static VTABLE: RawWakerVTable = RawWakerVTable::new(
62 61| | |_| unsafe { unreachable_unchecked() }, // clone
65 64| | |_| unsafe { unreachable_unchecked() }, // wake
68 67| | |_| unsafe { unreachable_unchecked() }, // wake_by_ref
73 72| | let waker = unsafe { Waker::from_raw(RawWaker::new(core::ptr::null(), &VTABLE)) };
74 73| | let mut context = Context::from_waker(&waker);
77 76| | if let Poll::Ready(val) = future.as_mut().poll(&mut context) {