IAsyncBatchObservable<T> 인터페이스

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.1.0

이 인터페이스는 IAsyncObserver 인터페이스를 일반화하여 항목 일괄 처리의 프로덕션 및 사용을 허용합니다.

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

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

형식 매개 변수

T

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

파생

Orleans.Streams.IAsyncStream<T>

메서드

SubscribeAsync(IAsyncBatchObserver<T>)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다.

확장 메서드

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