StreamSubscriptionHandle<T> 클래스

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.1.0

이 구독을 나타내는 핸들입니다. 소비자는 나중에 구독을 취소하기 위해 핸들을 직렬화하고 저장할 수 있습니다(예: 이 조직의 다른 활성화).

[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>

[<System.Serializable>]
[<Orleans.GenerateSerializer>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>

Public MustInherit Class StreamSubscriptionHandle(Of T)
Implements IEquatable(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

상속

Object

StreamSubscriptionHandle<T>

특성

SerializableAttribute GenerateSerializerAttribute

구현

IEquatable<StreamSubscriptionHandle<T>>

생성자

StreamSubscriptionHandle<T>()

이 구독을 나타내는 핸들입니다. 소비자는 나중에 구독을 취소하기 위해 핸들을 직렬화하고 저장할 수 있습니다(예: 이 조직의 다른 활성화).

속성

HandleId	이 StreamSubscriptionHandle에 대한 고유 식별자를 가져옵니다.
ProviderName	공급자의 이름을 가져옵니다.
StreamId	스트림 식별자를 가져옵니다.

메서드

Equals(StreamSubscriptionHandle<T>)	이 구독을 나타내는 핸들입니다. 소비자는 나중에 구독을 취소하기 위해 핸들을 직렬화하고 저장할 수 있습니다(예: 이 조직의 다른 활성화).
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	구독에서 스트림으로의 일괄 처리 사용을 다시 시작합니다.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	구독에서 스트림으로의 소비를 다시 시작합니다.
UnsubscribeAsync()	이 관찰 가능한 스트림 소비자의 구독을 취소합니다.

확장 메서드

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.