Searched refs:writer (Results 1 – 5 of 5) sorted by relevance
78 let mut writer = self.statuses.write().await; in set_service_status() localVariable79 match writer.get(service_name) { in set_service_status()88 writer.insert(service_name.to_string(), watch::channel(status)); in set_service_status()95 let mut writer = self.statuses.write().await; in clear_service_status() localVariable96 let _ = writer.remove(service_name); in clear_service_status()
131 let mut writer = BufWriter::new(File::create(path).unwrap()); in write_fds() localVariable132 writer.write_all(content.as_bytes()).unwrap(); in write_fds()
31 serde_json::to_writer(buf.writer(), &item).map_err(|e| Status::internal(e.to_string())) in encode()
223 let mut out_writer = out_buf.writer(); in compress()275 let mut out_writer = out_buf.writer(); in decompress()
216 // For example, updating a cloud project may require the `writer` permission