Lines Matching refs:Closed

65     Closed(Cause),  enumerator
117 Closed(Cause::EndStream) in send_open()
154 Closed(Cause::EndStream) in recv_open()
171 Closed(Cause::EndStream) in recv_open()
212 self.inner = Closed(Cause::EndStream); in recv_close()
231 Closed(..) if !queued => {}, in recv_reset()
251 self.inner = Closed(Cause::Proto(reason)); in recv_reset()
262 Closed(..) => {}, in recv_err()
265 self.inner = Closed(match *err { in recv_err()
275 Closed(..) => {}, in recv_eof()
278 self.inner = Closed(Cause::Io); in recv_eof()
295 self.inner = Closed(Cause::EndStream); in send_close()
303 self.inner = Closed(Cause::LocallyReset(reason)); in set_reset()
309 self.inner = Closed(Cause::Scheduled(reason)); in set_scheduled_reset()
314 Closed(Cause::Scheduled(reason)) => Some(reason), in get_scheduled_reset()
321 Closed(Cause::Scheduled(..)) => true, in is_scheduled_reset()
328 Closed(Cause::LocallyReset(_)) => true, in is_local_reset()
329 Closed(Cause::Scheduled(..)) => true, in is_local_reset()
337 Closed(Cause::EndStream) => false, in is_reset()
338 Closed(_) => true, in is_reset()
381 Closed(_) => true, in is_closed()
388 Closed(..) | HalfClosedRemote(..) => true, in is_recv_closed()
395 Closed(..) | HalfClosedLocal(..) | ReservedRemote => true, in is_send_closed()
410 Closed(Cause::Proto(reason)) | in ensure_recv_open()
411 Closed(Cause::LocallyReset(reason)) | in ensure_recv_open()
412 Closed(Cause::Scheduled(reason)) => Err(proto::Error::Proto(reason)), in ensure_recv_open()
413 Closed(Cause::Io) => Err(proto::Error::Io(io::ErrorKind::BrokenPipe.into())), in ensure_recv_open()
414 Closed(Cause::EndStream) | in ensure_recv_open()
423 Closed(Cause::Proto(reason)) | in ensure_reason()
424 Closed(Cause::LocallyReset(reason)) | in ensure_reason()
425 Closed(Cause::Scheduled(reason)) => Ok(Some(reason)), in ensure_reason()
426 Closed(Cause::Io) => Err(proto::Error::Io(io::ErrorKind::BrokenPipe.into()).into()), in ensure_reason()