IAsyncObserver<T> 인터페이스

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.1.0

이 인터페이스는 표준 .NET IObserver 인터페이스를 일반화하여 항목의 비동기 프로덕션을 허용합니다.

이 인터페이스는 항목 소비자가 구현하고 항목 생산자가 호출(사용)합니다. 즉, 스트림의 소비자 엔드포인트는 이 인터페이스를 구현합니다.

public interface IAsyncObserver<in T>

type IAsyncObserver<'T> = interface

Public Interface IAsyncObserver(Of In T)

형식 매개 변수

T

관찰자가 사용하는 개체의 형식입니다.

이 형식 매개 변수는 반공변(Contravariant)입니다. 즉, 지정한 형식이나 더 적게 파생된 모든 형식을 사용할 수 있습니다. 공변성(Covariance) 및 반공변성(Contravariance)에 대한 자세한 내용은 제네릭의 공변성(Covariance) 및 반공변성(Contravariance)을 참조하세요.

파생

Orleans.Streams.IAsyncBatchProducer<T>

Orleans.Streams.IAsyncStream<T>

메서드

OnCompletedAsync()	스트림이 완료되었음을 소비자에게 알렸습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다.
OnErrorAsync(Exception)	스트림에 오류가 있음을 소비자에게 알 수 있습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다.
OnNextAsync(T, StreamSequenceToken)	다음 항목을 소비자에게 전달합니다. 이 메서드에서 반환된 작업은 소비자가 동작 보장을 충족할 수 있도록 항목의 처리를 충분히 처리한 경우 완료되어야 합니다. 소비자가 스트림의 생산자 엔드포인트인 경우 스트림 구현이 항목에 대한 책임을 수락하고 배달 보장을 충족할 수 있는 경우 작업이 완료됩니다. 예를 들어 지속성 큐를 기반으로 하는 스트림은 항목이 지속적으로 저장되면 작업을 완료합니다. 최대 한 번 배달에 최상의 노력을 제공하는 스트림은 이미 완료된 작업을 반환합니다. 생산자가 스트림의 (소비자 엔드포인트)인 경우 항목에 대한 책임을 수락한 경우 소비자 코드에서 작업을 완료해야 합니다. 특히 스트림 공급자가 최소 한 번 이상 배달을 보장하는 경우 소비자가 반환한 작업이 완료될 때까지 항목을 배달하는 것으로 간주해서는 안 됩니다.