IAsyncStream<T> 인터페이스

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

이 인터페이스는 생산자와 소비자 간의 분산 랑데부 역할을 하는 개체를 나타냅니다. Reactive Framework Subject 와 유사하며 또는 IObservable 인터페이스를 IObserver 구현합니다.

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream

type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>

Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

형식 매개 변수

T

스트림을 통과하는 개체의 형식입니다.

구현

IAsyncObservable<T> IAsyncObserver<T> IComparable<IAsyncStream<T>> IEquatable<IAsyncStream<T>> IAsyncBatchObservable<T> IAsyncBatchProducer<T> IAsyncStream

속성

StreamId

스트림 식별자를 가져옵니다. (다음에서 상속됨 IAsyncStream)

메서드

GetAllSubscriptionHandles()	이 스트림에 대한 호출자가 만든 모든 활성 구독 목록을 검색합니다.
OnCompletedAsync()	스트림이 완료되었음을 소비자에게 알렸습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다. (다음에서 상속됨 IAsyncObserver<T>)
OnErrorAsync(Exception)	스트림에 오류가 있음을 소비자에게 알 수 있습니다. 소비자가 스트림 닫기 처리를 완료하면 이 메서드에서 반환된 작업을 완료해야 합니다. (다음에서 상속됨 IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	다음 항목을 소비자에게 전달합니다. 동작 보장을 충족하기 위해 소비자가 항목의 처리를 충분히 처리한 경우 이 메서드에서 반환된 작업을 완료해야 합니다. 소비자가 스트림의 (생산자 엔드포인트)인 경우 스트림 구현이 항목에 대한 책임을 수락하고 배달 보장을 충족할 수 있는 경우 작업이 완료됩니다. 예를 들어 지속성 큐를 기반으로 하는 스트림은 항목이 영구적으로 저장되면 작업을 완료합니다. 최대 한 번 배달에 최상의 노력을 제공하는 스트림은 이미 완료된 작업을 반환합니다. 생산자가 스트림의 (소비자 엔드포인트)인 경우 항목에 대한 책임을 수락한 경우 소비자 코드에서 작업을 완료해야 합니다. 특히 스트림 공급자가 최소 한 번의 배달을 보장하는 경우 소비자가 반환한 작업이 완료될 때까지 항목이 배달된 것으로 간주해서는 안 됩니다. (다음에서 상속됨 IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	다음 항목 일괄 처리를 소비자에게 전달합니다. 일괄 처리의 모든 항목이 모든 동작 보장을 충족하기 위해 소비자가 충분히 처리한 경우 이 메서드에서 반환된 작업을 완료해야 합니다. 즉, 반환된 작업의 의미 체계는 일괄 처리의 모든 항목에 OnNextAsync(T, StreamSequenceToken)대해 확장된 의 의미 체계와 동일합니다. (다음에서 상속됨 IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다. (다음에서 상속됨 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	소비자를 관찰 가능한 이 일괄 처리에 구독합니다. (다음에서 상속됨 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	소비자를 이 관찰 가능으로 구독합니다. (다음에서 상속됨 IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	소비자를 이 관찰 가능으로 구독합니다. (다음에서 상속됨 IAsyncObservable<T>)

확장 메서드

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