AsyncBatchObservableExtensions.SubscribeAsync 메서드
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
오버로드
| 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<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>)
대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncBatchObservable.SubscribeAsync에 대한 도우미로, IAsyncBatchObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 만들 수 있습니다.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task)) As Task(Of StreamSubscriptionHandle(Of T))형식 매개 변수
- T
관찰 가능 개체에 의해 생성된 개체의 형식입니다.
매개 변수
Observable 개체입니다.
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync에 대해 호출되는 대리자입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.
적용 대상
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)
대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncBatchObservable.SubscribeAsync에 대한 도우미로, IAsyncBatchObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 만들 수 있습니다.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))형식 매개 변수
- T
관찰 가능 개체에 의해 생성된 개체의 형식입니다.
매개 변수
Observable 개체입니다.
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync에 대해 호출되는 대리자입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.
적용 대상
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)
대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncBatchObservable.SubscribeAsync에 대한 도우미로, IAsyncBatchObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 만들 수 있습니다.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))형식 매개 변수
- T
관찰 가능 개체에 의해 생성된 개체의 형식입니다.
매개 변수
Observable 개체입니다.
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync에 대해 호출되는 대리자입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.
적용 대상
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)
대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncBatchObservable.SubscribeAsync에 대한 도우미로, IAsyncBatchObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 만들 수 있습니다.
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))형식 매개 변수
- T
관찰 가능 개체에 의해 생성된 개체의 형식입니다.
매개 변수
Observable 개체입니다.
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync에 대해 호출되는 대리자입니다.
반환
구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.