Class Observables

Inheritance

object

Observables

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: PoeShared.Scaffolding

Assembly: PoeShared.dll

Syntax

public static class Observables

Methods

Name	Description
BlockingTimer(TimeSpan, string, bool?)	This timer waits for callback completion before proceeding to the next tick
FromAsyncSafe(Func<CancellationToken, Task>)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe(Func<CancellationToken, Task>, IScheduler)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe(Func<Task>)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe(Func<Task>, IScheduler)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe<TResult>(Func<CancellationToken, Task<TResult>>)	Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started. The CancellationToken passed to the asynchronous function is tied to the observable sequence's subscription that triggered the function's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe<TResult>(Func<CancellationToken, Task<TResult>>, IScheduler)	Converts an asynchronous function into an observable sequence. Each subscription to the resulting sequence causes the function to be started. The CancellationToken passed to the asynchronous function is tied to the observable sequence's subscription that triggered the function's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe<T>(Func<Task<T>>)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
FromAsyncSafe<T>(Func<Task<T>>, IScheduler)	Converts an asynchronous action into an observable sequence. Each subscription to the resulting sequence causes the action to be started. The CancellationToken passed to the asynchronous action is tied to the observable sequence's subscription that triggered the action's invocation and can be used for best-effort cancellation. Sets ignoreExceptionsAfterUnsubscribe to true to ignore post-unsub exceptions which tend to be propagated to app domain and crash the app
PeriodicAsync(TimeSpan, Func<CancellationToken, Task>)
PeriodicAsync<T>(TimeSpan, Func<CancellationToken, Task<T>>)
Using<T>(Action<CompositeDisposable>)
Using<T>(Func<T>)