Method new

crates/wasi/src/p2/write_stream.rs:41–53

(write_budget: usize)

impl Worker {
    fn new(write_budget: usize) -> Self {
        Self {
            state: Mutex::new(WorkerState {
                alive: true,
                items: std::collections::VecDeque::new(),
                write_budget,
                flush_pending: false,
                error: None,
                write_ready_changed: None,
            }),
            new_work: tokio::sync::Notify::new(),
        }
    }
    fn check_write(&self) -> Result<usize, StreamError> {
        let mut state = self.state();
        if let Err(e) = state.check_error() {