Searched refs:WriteState (Results 1 – 3 of 3) sorted by relevance
267 enum WriteState<IO> { enum277 impl<IO> WriteState<IO> implementation296 let WriteState::Ready(mut stream) = std::mem::replace(self, WriteState::Closed) else { in write() localVariable316 let WriteState::Ready(mut stream) = std::mem::replace(self, WriteState::Closed) in flush() localVariable328 let WriteState::Writing(write) = std::mem::replace(self, WriteState::Closed) else { in flush() localVariable338 WriteState::Flushing(_) | WriteState::Closing(_) | WriteState::Error(_) => {} in flush()353 let WriteState::Error(e) = std::mem::replace(self, WriteState::Closed) else { in check_write() localVariable372 WriteState::Writing(op) | WriteState::Flushing(op) => { in close()382 WriteState::Closed | WriteState::Error(_) => {} in close()388 WriteState::Writing(task) | WriteState::Flushing(task) => _ = task.cancel().await, in cancel()[all …]
126 state: WriteState,129 enum WriteState { enum141 state: WriteState::Ready, in new()188 WriteState::Ready => {} in write()190 WriteState::Writing(_) | WriteState::Closing(_) | WriteState::Error(_) => { in write()227 WriteState::Ready in flush()228 | WriteState::Writing(_) in flush()245 WriteState::Ready => { in check_write()263 WriteState::Ready => { in shutdown()265 WriteState::Closed in shutdown()[all …]
2102 write: WriteState,2154 enum WriteState { enum2180 impl fmt::Debug for WriteState { implementation2357 WriteState::Dropped in host_drop_reader()2359 WriteState::Open in host_drop_reader()2385 WriteState::Open => { in host_drop_reader()2823 WriteState::Open => { in set_consumer()3681 WriteState::Dropped in guest_read()3683 WriteState::Open in guest_read()3833 WriteState::Open => { in guest_read()[all …]