ConnectableObservable<T> Class

Inheritance Hierarchy

System.Object
  Microsoft.Phone.Reactive.ConnectableObservable<T>

Namespace:  Microsoft.Phone.Reactive
Assembly:  Microsoft.Phone.Reactive (in Microsoft.Phone.Reactive.dll)

Syntax

'Declaration
Public Class ConnectableObservable(Of T) _
    Implements IConnectableObservable(Of T), IObservable(Of T)
public class ConnectableObservable<T> : IConnectableObservable<T>, 
    IObservable<T>
generic<typename T>
public ref class ConnectableObservable : IConnectableObservable<T>, 
    IObservable<T>
type ConnectableObservable<'T> =  
    class 
        interface IConnectableObservable<'T>
        interface IObservable<'T>
    end

Type Parameters

  • T

The ConnectableObservable<T> type exposes the following members.

Constructors

  Name Description
Public method ConnectableObservable<T>(IObservable<T>)
Public method ConnectableObservable<T>(IObservable<T>, ISubject<T>)

Top

Methods

  Name Description
Public method Connect
Public method Equals(Object) Determines whether the specified object is equal to the current object. (Inherited from Object.)
Protected method Finalize Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.)
Public method GetHashCode Serves as the default hash function. (Inherited from Object.)
Public method GetType Gets the Type of the current instance. (Inherited from Object.)
Protected method MemberwiseClone Creates a shallow copy of the current Object. (Inherited from Object.)
Public method Subscribe
Public method ToString Returns a string that represents the current object. (Inherited from Object.)

Top

Extension Methods

  Name Description
Public Extension Method Aggregate<T>(Func<T, T, T>) Overloaded. (Defined by Observable.)
Public Extension Method Aggregate<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>) Overloaded. (Defined by Observable.)
Public Extension Method All<T> (Defined by Observable.)
Public Extension Method Amb<T> (Defined by Observable.)
Public Extension Method And<T, TRight> (Defined by Observable.)
Public Extension Method Any<T>() Overloaded. (Defined by Observable.)
Public Extension Method Any<T>(Func<T, Boolean>) Overloaded. (Defined by Observable.)
Public Extension Method AsObservable<T> (Defined by Observable.)
Public Extension Method BufferWithCount<T>(Int32) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithCount<T>(Int32, Int32) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTime<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTime<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTime<T>(TimeSpan, TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTime<T>(TimeSpan, TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTimeOrCount<T>(TimeSpan, Int32) Overloaded. (Defined by Observable.)
Public Extension Method BufferWithTimeOrCount<T>(TimeSpan, Int32, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Catch<T>(IObservable<T>) Overloaded. (Defined by Observable.)
Public Extension Method Catch<T, TException>(Func<TException, IObservable<T>>) Overloaded. (Defined by Observable.)
Public Extension Method CombineLatest<T, TRight, TResult> (Defined by Observable.)
Public Extension Method Concat<T> (Defined by Observable.)
Public Extension Method Contains<T>(T) Overloaded. (Defined by Observable.)
Public Extension Method Contains<T>(T, IEqualityComparer<T>) Overloaded. (Defined by Observable.)
Public Extension Method Count<T> (Defined by Observable.)
Public Extension Method Delay<T>(DateTimeOffset) Overloaded. (Defined by Observable.)
Public Extension Method Delay<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Delay<T>(DateTimeOffset, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Delay<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method DistinctUntilChanged<T>() Overloaded. (Defined by Observable.)
Public Extension Method DistinctUntilChanged<T>(IEqualityComparer<T>) Overloaded. (Defined by Observable.)
Public Extension Method DistinctUntilChanged<T, TKey>(Func<T, TKey>) Overloaded. (Defined by Observable.)
Public Extension Method DistinctUntilChanged<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Overloaded. (Defined by Observable.)
Public Extension Method Do<T>(Action<T>) Overloaded. (Defined by Observable.)
Public Extension Method Do<T>(IObserver<T>) Overloaded. (Defined by Observable.)
Public Extension Method Do<T>(Action<T>, Action) Overloaded. (Defined by Observable.)
Public Extension Method Do<T>(Action<T>, Action<Exception>) Overloaded. (Defined by Observable.)
Public Extension Method Do<T>(Action<T>, Action<Exception>, Action) Overloaded. (Defined by Observable.)
Public Extension Method Finally<T> (Defined by Observable.)
Public Extension Method First<T> (Defined by Observable.)
Public Extension Method FirstOrDefault<T> (Defined by Observable.)
Public Extension Method ForkJoin<T, TRight, TResult> (Defined by Observable.)
Public Extension Method GetEnumerator<T> (Defined by Observable.)
Public Extension Method GroupBy<T, TKey>(Func<T, TKey>) Overloaded. (Defined by Observable.)
Public Extension Method GroupBy<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Overloaded. (Defined by Observable.)
Public Extension Method GroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Overloaded. (Defined by Observable.)
Public Extension Method GroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>, IEqualityComparer<TKey>) Overloaded. (Defined by Observable.)
Public Extension Method IsEmpty<T> (Defined by Observable.)
Public Extension Method Last<T> (Defined by Observable.)
Public Extension Method LastOrDefault<T> (Defined by Observable.)
Public Extension Method Latest<T> (Defined by Observable.)
Public Extension Method Let<T, TResult> (Defined by Observable.)
Public Extension Method LongCount<T> (Defined by Observable.)
Public Extension Method Materialize<T> (Defined by Observable.)
Public Extension Method Max<T>() Overloaded. (Defined by Observable.)
Public Extension Method Max<T>(IComparer<T>) Overloaded. (Defined by Observable.)
Public Extension Method MaxBy<T, TKey>(Func<T, TKey>) Overloaded. (Defined by Observable.)
Public Extension Method MaxBy<T, TKey>(Func<T, TKey>, IComparer<TKey>) Overloaded. (Defined by Observable.)
Public Extension Method Merge<T>(IObservable<T>) Overloaded. (Defined by Observable.)
Public Extension Method Merge<T>(IObservable<T>, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Min<T>() Overloaded. (Defined by Observable.)
Public Extension Method Min<T>(IComparer<T>) Overloaded. (Defined by Observable.)
Public Extension Method MinBy<T, TKey>(Func<T, TKey>) Overloaded. (Defined by Observable.)
Public Extension Method MinBy<T, TKey>(Func<T, TKey>, IComparer<TKey>) Overloaded. (Defined by Observable.)
Public Extension Method MostRecent<T> (Defined by Observable.)
Public Extension Method Next<T> (Defined by Observable.)
Public Extension Method ObserveOn<T>(Dispatcher) Overloaded. (Defined by DispatcherObservableExtensions.)
Public Extension Method ObserveOn<T>(DispatcherScheduler) Overloaded. (Defined by Observable.)
Public Extension Method ObserveOn<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method ObserveOn<T>(SynchronizationContext) Overloaded. (Defined by Observable.)
Public Extension Method ObserveOnDispatcher<T> (Defined by Observable.)
Public Extension Method OnErrorResumeNext<T> (Defined by Observable.)
Public Extension Method Prune<T>() Overloaded. (Defined by Observable.)
Public Extension Method Prune<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Prune<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method Prune<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Publish<T>() Overloaded. (Defined by Observable.)
Public Extension Method Publish<T>(T) Overloaded. (Defined by Observable.)
Public Extension Method Publish<T>(T, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Publish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method Publish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T) Overloaded. (Defined by Observable.)
Public Extension Method Publish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method RefCount<T> (Defined by Observable.)
Public Extension Method Repeat<T>() Overloaded. (Defined by Observable.)
Public Extension Method Repeat<T>(Int32) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>() Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(Int32) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(Int32, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(Int32, TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T>(Int32, TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Retry<T>() Overloaded. (Defined by Observable.)
Public Extension Method Retry<T>(Int32) Overloaded. (Defined by Observable.)
Public Extension Method Run<T>() Overloaded. (Defined by Observable.)
Public Extension Method Run<T>(Action<T>) Overloaded. (Defined by Observable.)
Public Extension Method Run<T>(IObserver<T>) Overloaded. (Defined by Observable.)
Public Extension Method Run<T>(Action<T>, Action) Overloaded. (Defined by Observable.)
Public Extension Method Run<T>(Action<T>, Action<Exception>) Overloaded. (Defined by Observable.)
Public Extension Method Run<T>(Action<T>, Action<Exception>, Action) Overloaded. (Defined by Observable.)
Public Extension Method Sample<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Sample<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Scan<T>(Func<T, T, T>) Overloaded. (Defined by Observable.)
Public Extension Method Scan<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>) Overloaded. (Defined by Observable.)
Public Extension Method Scan0<T, TAccumulate> (Defined by Observable.)
Public Extension Method Select<T, TResult>(Func<T, TResult>) Overloaded. (Defined by Observable.)
Public Extension Method Select<T, TResult>(Func<T, Int32, TResult>) Overloaded. (Defined by Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IObservable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IEnumerable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method SelectMany<T, TOther>(IObservable<TOther>) Overloaded. (Defined by Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) Overloaded. (Defined by Observable.)
Public Extension Method SelectMany<T, TCollection, TResult>(Func<T, IObservable<TCollection>>, Func<T, TCollection, TResult>) Overloaded. (Defined by Observable.)
Public Extension Method Single<T> (Defined by Observable.)
Public Extension Method SingleOrDefault<T> (Defined by Observable.)
Public Extension Method Skip<T> (Defined by Observable.)
Public Extension Method SkipLast<T> (Defined by Observable.)
Public Extension Method SkipUntil<T, TOther> (Defined by Observable.)
Public Extension Method SkipWhile<T> (Defined by Observable.)
Public Extension Method StartWith<T>(array<T[]) Overloaded. (Defined by Observable.)
Public Extension Method StartWith<T>(IScheduler, array<T[]) Overloaded. (Defined by Observable.)
Public Extension Method Subscribe<T>() Overloaded. (Defined by ObservableExtensions.)
Public Extension Method Subscribe<T>(Action<T>) Overloaded. (Defined by ObservableExtensions.)
Public Extension Method Subscribe<T>(Action<T>, Action<Exception>) Overloaded. (Defined by ObservableExtensions.)
Public Extension Method Subscribe<T>(Action<T>, Action) Overloaded. (Defined by ObservableExtensions.)
Public Extension Method Subscribe<T>(Action<T>, Action<Exception>, Action) Overloaded. (Defined by ObservableExtensions.)
Public Extension Method SubscribeOn<T>(Dispatcher) Overloaded. (Defined by DispatcherObservableExtensions.)
Public Extension Method SubscribeOn<T>(DispatcherScheduler) Overloaded. (Defined by Observable.)
Public Extension Method SubscribeOn<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method SubscribeOn<T>(SynchronizationContext) Overloaded. (Defined by Observable.)
Public Extension Method SubscribeOnDispatcher<T> (Defined by Observable.)
Public Extension Method Synchronize<T>() Overloaded. (Defined by Observable.)
Public Extension Method Synchronize<T>(Object) Overloaded. (Defined by Observable.)
Public Extension Method Take<T>(Int32) Overloaded. (Defined by Observable.)
Public Extension Method Take<T>(Int32, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method TakeLast<T> (Defined by Observable.)
Public Extension Method TakeUntil<T, TOther> (Defined by Observable.)
Public Extension Method TakeWhile<T> (Defined by Observable.)
Public Extension Method Then<T, TResult> (Defined by Observable.)
Public Extension Method Throttle<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Throttle<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method TimeInterval<T>() Overloaded. (Defined by Observable.)
Public Extension Method TimeInterval<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(DateTimeOffset) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(TimeSpan) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(DateTimeOffset, IObservable<T>) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(DateTimeOffset, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(TimeSpan, IObservable<T>) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(TimeSpan, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(DateTimeOffset, IObservable<T>, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Timeout<T>(TimeSpan, IObservable<T>, IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method Timestamp<T>() Overloaded. (Defined by Observable.)
Public Extension Method Timestamp<T>(IScheduler) Overloaded. (Defined by Observable.)
Public Extension Method ToEnumerable<T> (Defined by Observable.)
Public Extension Method Where<T>(Func<T, Boolean>) Overloaded. (Defined by Observable.)
Public Extension Method Where<T>(Func<T, Int32, Boolean>) Overloaded. (Defined by Observable.)
Public Extension Method Zip<T, TRight, TResult>(IEnumerable<TRight>, Func<T, TRight, TResult>) Overloaded. (Defined by Observable.)
Public Extension Method Zip<T, TRight, TResult>(IObservable<TRight>, Func<T, TRight, TResult>) Overloaded. (Defined by Observable.)

Top

Version Information

.NET for Windows Phone apps

Supported in: Windows Phone 8, Silverlight 8.1

Thread Safety

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

See Also

Reference

Microsoft.Phone.Reactive Namespace