fuchsia_fuzzctl_test/
util.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
// Copyright 2022 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

use anyhow::Result;
use fuchsia_async as fasync;
use fuchsia_fuzzctl::{OutputSink, Writer};
use futures::Future;

/// Wraps a given `future` to display any returned errors using the given `writer`.
pub fn create_task<F, O>(future: F, writer: &Writer<O>) -> fasync::Task<()>
where
    F: Future<Output = Result<()>> + 'static,
    O: OutputSink,
{
    let writer = writer.clone();
    let wrapped = || async move {
        if let Err(e) = future.await {
            writer.error(format!("task failed: {:?}", e));
        }
    };
    fasync::Task::local(wrapped())
}