다음을 통해 공유


StreamSubscriptionHandleExtensions.ResumeAsync 메서드

정의

오버로드

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,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<Task>, StreamSequenceToken)

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,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>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

제공된 스트림 필터 함수가 적합하지 않은 경우 throw됩니다. 일반적으로 정적 메서드가 아니기 때문입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 구독 클래스가 IAsyncBatchObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인할 수 있도록 하는 StreamSubscriptionHandle.ResumeAsync의 도우미입니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, 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, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'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> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<IList<SequentialItem<T>>,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync에 대해 호출되는 대리자입니다.

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독이 명시적으로 구독 취소되지 않는 한 구독은 활성 상태로 유지됩니다.

적용 대상

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Source:
StreamSubscriptionHandleExtensions.cs

대리자를 사용하여 스트림 사용을 다시 시작합니다. 이 메서드는 StreamSubscriptionHandle.ResumeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 연결할 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);
static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

관찰 가능 개체에 의해 생성된 개체의 형식입니다.

매개 변수

handle
StreamSubscriptionHandle<T>

구독 핸들입니다.

onNextAsync
Func<T,StreamSequenceToken,Task>

IAsyncObserver.OnNextAsync에 대해 호출되는 대리자입니다.

onErrorAsync
Func<Exception,Task>

IAsyncObserver.OnErrorAsync에 대해 호출되는 대리자입니다.

onCompletedAsync
Func<Task>

IAsyncObserver.OnCompletedAsync에 대해 호출되는 대리자입니다.

token
StreamSequenceToken

구독을 시작하는 오프셋으로 사용할 스트림 시퀀스입니다.

반환

구독을 나타내는 StreamSubscriptionHandle에 대한 약속입니다. 소비자는 이 핸들을 사용하여 구독을 취소할 수 있습니다. 구독은 명시적으로 구독을 취소하지 않는 한 활성 상태로 유지됩니다.

적용 대상