IAsyncObservable<T> 인터페이스

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

이 인터페이스는 표준 .NET IObserveable 인터페이스를 일반화하여 항목의 비동기 사용을 허용합니다. 여기서 비동기적으로는 소비자가 반환된 작업을 완료하여 항목을 비동기적으로 처리하고 생산자에게 항목 완성을 신호로 보낼 수 있음을 의미합니다.

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

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

파생

Orleans.Streams.IAsyncStream<T>

메서드

SubscribeAsync(IAsyncObserver<T>)	이 관찰 가능한 소비자를 구독합니다.
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	이 관찰 가능한 소비자를 구독합니다.

확장 메서드

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.