IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) 메서드

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.1.0

다음 항목을 소비자에게 전달합니다.

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

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

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

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);

abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task

Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

매개 변수

item

T

전달할 항목입니다.

token

StreamSequenceToken

이 항목의 스트림 시퀀스 토큰입니다.

반환

Task

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