[WWDC 2021] Meet AsyncSequence

한마디로 요약하자면 sequence protocol에 async 기능을 가능하게 한 protocol 
async/ await 키워드를 사용해 비동기를 좀 더 편리하게 다루게 했는데 collection type에 대해 우리는 for, while 같은 sequence 루프를 많이 사용한단 말이지 ?
ㅇㅋㅇㅋ 이에 대한 async도 만들겠음 해서 만들어진 프로토콜 --> AsyncSequence

즉 sequence를 비동기적으로 만들겠다는 것만 다릅니다 세션에서도 sequence를 알고 있다면 이미 asynceSequence를 아는것과 다름이 없다고 언급하고 있는데요 세션 내용을 정리해봅시다.

 

asyncSequence를 사용한 코드는 위와 같습니다.
코드를 보면 만들어진 url의 lines에 대해 첫번째 줄을 읽고 drop하는 dropFirst() 함수를 통해 한줄씩 event 변수로 읽고 있는데여

 

요 구문을 자세히 보면 line의 비동기 시퀀스가 response 되는대로 각 라인을 방출하고 있습니다.

 

오호 await 하고 있는 함수의 return 값이 AsyncDropFirstSequence이고 이는 

AsyncSequece 프로토콜을 준수하고 있는걸 볼 수 있습니다.

그렇다면 sequence와 asyncSequence는 뭐가 다를까요 ?
일반 sequence와 같지만 몇가지 다른점이 있습니다.

1. 각 요소는 비동기적으로 반환됩니다.
2. 비동기 전달이기 때문에 실패할 가능성이 있고 이를 throw 할 수 있습니다.
3. error가 발생하거나 throw 되면 종류됩니다. 

 

일반적인 for in 루프의 경우입니다.
시퀀스에서 지진을 반복한 다음 크기가 특정 값을 초과하면 displaySignificantEarthquake() 함수를 호출하고 있습니다.

컴파일러는 이를 아래와 같은 방법으로 처리합니다.

makeIterator() 함수는 Sequence 프로토콜을 채택하면 가지게 되는 함수이죠.

quakes를 makeIterator()를 통해 interator로 만든 다음 만들어진 iterator 변수를 사용해 next가 호출될때 iterator가 생성한 모든 지진을 가져옵니다.

이를 비동기를 사용해 가져오는 코드르 변경하면 아래와 같습니다.

만약 가져오는 quakes sequence가 다운로드 작업이 필요하다면 

try를 사용해 error를 throw할수 있도록 해야 합니다.

 

두개의 for in 문은 첫번째 for in 문이 실행된 후 아래 for in 문이 실행되는데요. 

 

이를 비동기적으로 실행하기 위해선

Task로 캡슐화 하여 병렬적으로 실행 할 수도 있습니다.

 

두개의 반복을 동시에 실행하고 나중에 반복을 종료할 수도 있습니다.


asyncSequence를 사용할 수 있는 sequence 프로토콜의 property들을 소개하고 있네요 !!

자신만의 비동기 시퀀스를 만드는 방법에 대해 소개하겠습니다. 비동기 시퀀스는 callBack을 사용하거나 delegate 패턴을 사용할때 매우 유용한데요.

handler 패턴을 사용하는 예시를 봐봅시다.

QuakeMonitor라는 클래스가 있습니다.
클래스 안에는 핸들러와 quake 모니터를 시작하고, 중지하는 함수가 정의되어 있습니다.

 

기존 사용법은 모니터 클래스를 생성하고 값을 가져오는 handler를 할당한 다음 모니터링을 시작하여 handler에게 지진의 값을 보내고 나중에 모니터링을 중지합니다.

 

이를 AsyncStream을 사용해 asyncSequence를 생성 할 수 있습니다.

AsyncStream의 클로저로 continuation을 받아오는데요. continuation을 통해 handler에서 quake를 만들어내고(yield),  onTermination을 통해 모니터링을 stop할 수 있습니다. 다음 모니터링을 시작할 수 있습니다.

이전에 사용했던 것과 동일한 모니터 코드를 비동기 스트림 구성 내에서 쉽게 캡슐화할 수 있습니다.
그리고 아래와 같이 asyncStream을 사용합니다. 

 

AsyncStream을 사용해 고유한 asyncSequence를 생성할 수 있으며 buffering과 cancellation을 처리하는데 유용합니다.

 

오류를 나타내야 한다면 ?

AsyncThrowingStream을 통해 error를 처리합니다.

 

asyncStream에 대해선

https://minsone.github.io/swift-concurrency-asyncstream-AsyncThrowingStream

https://zeddios.tistory.com/1341

블로그에서 더 자세하게 예시를 확인 할 수 있습니다.

AsyncSequence는 둘 이상의 비동기 값을 처리하는 데 안전하고 친숙한 매우 강력한 도구입니다.