IAsyncBatchObserver<T>.OnNextAsync 메서드

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

다음 항목 일괄 처리를 소비자에게 전달합니다.

동작 보장을 충족하기 위해 소비자가 항목의 처리를 충분히 처리한 경우 이 메서드에서 반환된 작업을 완료해야 합니다.

소비자가 스트림의 (생산자 엔드포인트)이면 스트림 구현이 항목에 대한 책임을 수락하고 배달 보장을 충족할 수 있을 때 작업이 완료됩니다. 예를 들어 지속성 큐를 기반으로 하는 스트림은 항목이 영구적으로 저장되면 작업을 완료합니다. 최대 한 번 배달에 최상의 노력을 제공하는 스트림은 이미 완료된 작업을 반환합니다.

생산자가 스트림의 (소비자 엔드포인트)인 경우 항목에 대한 책임을 수락한 경우 소비자 코드에서 작업을 완료해야 합니다. 특히 스트림 공급자가 한 번 이상 배달을 보장하는 경우 소비자가 반환한 작업이 완료될 때까지 항목을 배달된 것으로 간주해서는 안 됩니다.

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);

abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task

Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

매개 변수

items

IList<SequentialItem<T>>

전달할 항목입니다.

반환

Task

항목이 수락되면 완료되는 작업입니다.