IAsyncBatchProducer<T> 인터페이스
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
이 인터페이스는 항목 일괄 처리를 생성할 수 있도록 IAsyncObserver 인터페이스를 일반화합니다.
이 인터페이스는 항목 생산자가 호출(사용)합니다.
public interface IAsyncBatchProducer<T> : Orleans.Streams.IAsyncObserver<T>type IAsyncBatchProducer<'T> = interface
interface IAsyncObserver<'T>Public Interface IAsyncBatchProducer(Of T)
Implements IAsyncObserver(Of T)형식 매개 변수
- T
관찰자가 사용하는 개체의 형식입니다.
- 파생
- 구현
메서드
| OnCompletedAsync() |
스트림이 완료되었음을 소비자에게 알렸습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다. (다음에서 상속됨 IAsyncObserver<T>) |
| OnErrorAsync(Exception) |
스트림에 오류가 있음을 소비자에게 알 수 있습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다. (다음에서 상속됨 IAsyncObserver<T>) |
| OnNextAsync(T, StreamSequenceToken) |
다음 항목을 소비자에게 전달합니다. 동작 보장을 충족하기 위해 소비자가 항목의 처리를 충분히 처리한 경우 이 메서드에서 반환된 작업을 완료해야 합니다. 소비자가 스트림의 (생산자 엔드포인트)인 경우 스트림 구현이 항목에 대한 책임을 수락하고 배달 보장을 충족할 수 있는 경우 작업이 완료됩니다. 예를 들어 지속성 큐를 기반으로 하는 스트림은 항목이 영구적으로 저장되면 작업을 완료합니다. 최대 한 번 배달에 최상의 노력을 제공하는 스트림은 이미 완료된 작업을 반환합니다. 생산자가 스트림의 (소비자 엔드포인트)인 경우 항목에 대한 책임을 수락한 경우 소비자 코드에서 작업을 완료해야 합니다. 특히 스트림 공급자가 최소 한 번의 배달을 보장하는 경우 소비자가 반환한 작업이 완료될 때까지 항목이 배달된 것으로 간주해서는 안 됩니다. (다음에서 상속됨 IAsyncObserver<T>) |
| OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken) |
다음 항목 일괄 처리를 소비자에게 전달합니다. 일괄 처리의 모든 항목이 모든 동작 보장을 충족하기 위해 소비자가 충분히 처리한 경우 이 메서드에서 반환된 작업을 완료해야 합니다. 즉, 반환된 작업의 의미 체계는 일괄 처리의 모든 항목에 OnNextAsync(T, StreamSequenceToken)대해 확장된 의 의미 체계와 동일합니다. |