IAsyncObservable<T>.SubscribeAsync 메서드
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
오버로드
| SubscribeAsync(IAsyncObserver<T>) |
이 관찰 가능한 소비자를 구독합니다. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
이 관찰 가능한 소비자를 구독합니다. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
이 관찰 가능한 소비자를 구독합니다. |
SubscribeAsync(IAsyncObserver<T>)
- Source:
- IAsyncObservable.cs
이 관찰 가능한 소비자를 구독합니다.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))매개 변수
- observer
- IAsyncObserver<T>
구독할 비동기 관찰자입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독은 명시적으로 구독을 취소하지 않는 한 활성 상태로 유지됩니다.
적용 대상
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
이 관찰 가능한 소비자를 구독합니다.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken? token, string? filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * string -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterData As String = Nothing) As Task(Of StreamSubscriptionHandle(Of T))매개 변수
- observer
- IAsyncObserver<T>
구독할 비동기 관찰자입니다.
- token
- StreamSequenceToken
구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.
- filterData
- String
필터에 전달될 데이터 개체입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독은 명시적으로 구독을 취소하지 않는 한 활성 상태로 유지됩니다.
적용 대상
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- IAsyncObservable.cs
이 관찰 가능한 소비자를 구독합니다.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))매개 변수
- observer
- IAsyncObserver<T>
구독할 비동기 관찰자입니다.
- token
- StreamSequenceToken
구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.
- filterFunc
- StreamFilterPredicate
이 구독에 적용할 필터
- filterData
- Object
filterFunc에 전달될 데이터 개체입니다. 여기에는 일반적으로 filterFunc에서 필터링 결정을 내리는 데 필요한 모든 매개 변수가 포함됩니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독은 명시적으로 구독 취소되지 않는 한 활성 상태로 유지됩니다.
예외
제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.