컴파일러는 취소 안전에 도움이 되지 않습니다. API 문서를 읽고 async fn의 상태를 고려해야 합니다.

panic 및 ?와 달리 취소는 오류 처리가 아닌 일반적인 제어 흐름의 일부입니다.

이 예에서는 문자열의 일부가 손실됩니다.

• tick() 브랜치가 먼저 완료될 때마다 next() 및 buf가 삭제됩니다.

• 다음과 같이 buf를 구조체의 일부로 만들어 LinesReader가 취소되지 않도록 할 수 있습니다.

  #![allow(unused)]
  fn main() {
  struct LinesReader {
      stream: DuplexStream,
      bytes: Vec<u8>,
      buf: [u8; 1],
  }
  
  impl LinesReader {
      fn new(stream: DuplexStream) -> Self {
          Self { stream, bytes: Vec::new(), buf: [0] }
      }
      async fn next(&mut self) -> io::Result<Option<String>> {
          // buf 및 bytes 접두사를 self로 지정합니다.
          // ...
          let raw = std::mem::take(&mut self.bytes);
          let s = String::from_utf8(raw)
          // ...
      }
  }
  }

Interval::tick은 틱이 ‘delivered’ 됐는지 추적하므로 취소에 안전합니다.

AsyncReadExt::read는 데이터를 반환하거나 읽지 않으므로 취소에 안전합니다.

AsyncBufReadExt::read_line은 예와 유사하며 취소에 안전하지 않습니다. 자세한 내용과 대안은 관련 문서를 참고하세요.