AsyncObservableExtensions.SubscribeAsync 메서드

정의

네임스페이스:

Orleans.Streams

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.1.0

오버로드

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

반환

Task<StreamSubscriptionHandle<T>>

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

token

StreamSequenceToken

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

반환

Task<StreamSubscriptionHandle<T>>

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

예외

ArgumentException

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

반환

Task<StreamSubscriptionHandle<T>>

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onCompletedAsync

Func<Task>

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

반환

Task<StreamSubscriptionHandle<T>>

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, 구독 클래스가 IAsyncObserver 인스턴스를 요구하는 대신 처리기 메서드를 인라인으로 만들 수 있습니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

token

StreamSequenceToken

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

반환

Task<StreamSubscriptionHandle<T>>

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

예외

ArgumentException

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, IAsyncObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 연결할 수 있도록 합니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

onCompletedAsync

Func<Task>

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

반환

Task<StreamSubscriptionHandle<T>>

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, IAsyncObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 연결할 수 있도록 합니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

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

반환

Task<StreamSubscriptionHandle<T>>

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

예외

ArgumentException

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

대리자를 사용하여 이 관찰 가능한 소비자를 구독합니다. 이 메서드는 IAsyncObservable.SubscribeAsync에 대한 도우미로, IAsyncObserver 인스턴스를 요구하는 대신 구독 클래스가 처리기 메서드를 인라인으로 연결할 수 있도록 합니다.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, 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);

static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'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 SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

형식 매개 변수

T

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

매개 변수

obs

IAsyncObservable<T>

Observable 개체입니다.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

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

반환

Task<StreamSubscriptionHandle<T>>

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

예외

ArgumentException

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