UniRx

AnimationCurveReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.AnimationCurveReactiveProperty
    : ReactiveProperty<AnimationCurve>, IReactiveProperty<AnimationCurve>, IReadOnlyReactiveProperty<AnimationCurve>, IObservable<AnimationCurve>, IDisposable, IOptimizedObservable<AnimationCurve>, IObserverLinkedList<AnimationCurve>

AsyncMessageBroker

In-Memory PubSub filtered by Type.

public class UniRx.AsyncMessageBroker
    : IAsyncMessageBroker, IAsyncMessagePublisher, IAsyncMessageReceiver, IDisposable

Methods

Type	Name	Summary
void	Dispose()
IObservable<Unit>	PublishAsync(T message)
IDisposable	Subscribe(Func<T, IObservable<Unit>> asyncMessageReceiver)

Static Fields

Type	Name	Summary
IAsyncMessageBroker	Default	AsyncMessageBroker in Global scope.

AsyncOperationExtensions

public static class UniRx.AsyncOperationExtensions

Static Methods

Type	Name	Summary
IObservable<T>	AsAsyncOperationObservable(this T asyncOperation, IProgress<Single> progress = null)
IObservable<AsyncOperation>	AsObservable(this AsyncOperation asyncOperation, IProgress<Single> progress = null)	If you needs return value, use AsAsyncOperationObservable instead.

AsyncReactiveCommand

Variation of ReactiveCommand, when executing command then CanExecute = false after CanExecute = true.

public class UniRx.AsyncReactiveCommand
    : AsyncReactiveCommand<Unit>, IAsyncReactiveCommand<Unit>

Methods

Type	Name	Summary
IDisposable	Execute()

AsyncReactiveCommand<T>

Variation of ReactiveCommand, canExecute is changed when executing command then CanExecute = false after CanExecute = true.

public class UniRx.AsyncReactiveCommand<T>
    : IAsyncReactiveCommand<T>

Properties

Type	Name	Summary
IReadOnlyReactiveProperty<Boolean>	CanExecute
Boolean	IsDisposed

Methods

Type	Name	Summary
IDisposable	Execute(T parameter)	Push parameter to subscribers when CanExecute.
IDisposable	Subscribe(Func<T, IObservable<Unit>> asyncAction)	Subscribe execute.
UniTask<T>	WaitUntilExecuteAsync()

AsyncReactiveCommandExtensions

public static class UniRx.AsyncReactiveCommandExtensions

Static Methods

Type	Name	Summary
IDisposable	BindTo(this IAsyncReactiveCommand<Unit> command, Button button)	Bind AsyncRaectiveCommand to button's interactable and onClick.
IDisposable	BindToOnClick(this IAsyncReactiveCommand<Unit> command, Button button, Func<Unit, IObservable<Unit>> asyncOnClick)	Bind AsyncRaectiveCommand to button's interactable and onClick and register async action to command.
IDisposable	BindToOnClick(this Button button, Func<Unit, IObservable<Unit>> asyncOnClick)	Bind AsyncRaectiveCommand to button's interactable and onClick and register async action to command.
IDisposable	BindToOnClick(this Button button, IReactiveProperty<Boolean> sharedCanExecuteSource, Func<Unit, IObservable<Unit>> asyncOnClick)	Bind AsyncRaectiveCommand to button's interactable and onClick and register async action to command.
Awaiter<T>	GetAwaiter(this IAsyncReactiveCommand<T> command)
AsyncReactiveCommand	ToAsyncReactiveCommand(this IReactiveProperty<Boolean> sharedCanExecuteSource)
AsyncReactiveCommand<T>	ToAsyncReactiveCommand(this IReactiveProperty<Boolean> sharedCanExecuteSource)

AsyncSubject<T>

public class UniRx.AsyncSubject<T>
    : ISubject<T>, ISubject<T, T>, IObserver<T>, IObservable<T>, IOptimizedObservable<T>, IDisposable, INotifyCompletion

Properties

Type	Name	Summary
Boolean	HasObservers
Boolean	IsCompleted
T	Value

Methods

Type	Name	Summary
void	Dispose()
AsyncSubject<T>	GetAwaiter()	Gets an awaitable object for the current AsyncSubject.
T	GetResult()	Gets the last element of the subject, potentially blocking until the subject completes successfully or exceptionally.
Boolean	IsRequiredSubscribeOnCurrentThread()
void	OnCompleted()	Specifies a callback action that will be invoked when the subject completes.
void	OnCompleted(Action continuation)	Specifies a callback action that will be invoked when the subject completes.
void	OnError(Exception error)
void	OnNext(T value)
IDisposable	Subscribe(IObserver<T> observer)

BehaviorSubject<T>

public class UniRx.BehaviorSubject<T>
    : ISubject<T>, ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable, IOptimizedObservable<T>

Properties

Type	Name	Summary
Boolean	HasObservers
T	Value

Methods

Type	Name	Summary
void	Dispose()
Boolean	IsRequiredSubscribeOnCurrentThread()
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)
IDisposable	Subscribe(IObserver<T> observer)

BooleanDisposable

public class UniRx.BooleanDisposable
    : IDisposable, ICancelable

Properties

Type	Name	Summary
Boolean	IsDisposed

Methods

Type	Name	Summary
void	Dispose()

BooleanNotifier

Notify boolean flag.

public class UniRx.BooleanNotifier
    : IObservable<Boolean>

Properties

Type	Name	Summary
Boolean	Value	Current flag value

Methods

Type	Name	Summary
IDisposable	Subscribe(IObserver<Boolean> observer)	Subscribe observer.
void	SwitchValue()	Set and raise reverse value.
void	TurnOff()	Set and raise false if current value isn't false.
void	TurnOn()	Set and raise true if current value isn't true.

BoolReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.BoolReactiveProperty
    : ReactiveProperty<Boolean>, IReactiveProperty<Boolean>, IReadOnlyReactiveProperty<Boolean>, IObservable<Boolean>, IDisposable, IOptimizedObservable<Boolean>, IObserverLinkedList<Boolean>

BoundsReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.BoundsReactiveProperty
    : ReactiveProperty<Bounds>, IReactiveProperty<Bounds>, IReadOnlyReactiveProperty<Bounds>, IObservable<Bounds>, IDisposable, IOptimizedObservable<Bounds>, IObserverLinkedList<Bounds>

Properties

Type	Name	Summary
IEqualityComparer<Bounds>	EqualityComparer

ByteReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.ByteReactiveProperty
    : ReactiveProperty<Byte>, IReactiveProperty<Byte>, IReadOnlyReactiveProperty<Byte>, IObservable<Byte>, IDisposable, IOptimizedObservable<Byte>, IObserverLinkedList<Byte>

CancellationDisposable

Represents a disposable resource that has an associated that will be set to the cancellation requested state upon disposal.

public class UniRx.CancellationDisposable
    : ICancelable, IDisposable

Properties

Type	Name	Summary
Boolean	IsDisposed	Gets a value that indicates whether the object is disposed.
CancellationToken	Token	Gets the System.Threading.CancellationToken used by this CancellationDisposable.

Methods

Type	Name	Summary
void	Dispose()	Cancels the underlying .

CollectionAddEvent<T>

public struct UniRx.CollectionAddEvent<T>
    : IEquatable<CollectionAddEvent<T>>

Properties

Type	Name	Summary
Int32	Index
T	Value

Methods

Type	Name	Summary
Boolean	Equals(CollectionAddEvent<T> other)
Int32	GetHashCode()
String	ToString()

CollectionMoveEvent<T>

public struct UniRx.CollectionMoveEvent<T>
    : IEquatable<CollectionMoveEvent<T>>

Properties

Type	Name	Summary
Int32	NewIndex
Int32	OldIndex
T	Value

Methods

Type	Name	Summary
Boolean	Equals(CollectionMoveEvent<T> other)
Int32	GetHashCode()
String	ToString()

CollectionRemoveEvent<T>

public struct UniRx.CollectionRemoveEvent<T>
    : IEquatable<CollectionRemoveEvent<T>>

Properties

Type	Name	Summary
Int32	Index
T	Value

Methods

Type	Name	Summary
Boolean	Equals(CollectionRemoveEvent<T> other)
Int32	GetHashCode()
String	ToString()

CollectionReplaceEvent<T>

public struct UniRx.CollectionReplaceEvent<T>
    : IEquatable<CollectionReplaceEvent<T>>

Properties

Type	Name	Summary
Int32	Index
T	NewValue
T	OldValue

Methods

Type	Name	Summary
Boolean	Equals(CollectionReplaceEvent<T> other)
Int32	GetHashCode()
String	ToString()

ColorReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.ColorReactiveProperty
    : ReactiveProperty<Color>, IReactiveProperty<Color>, IReadOnlyReactiveProperty<Color>, IObservable<Color>, IDisposable, IOptimizedObservable<Color>, IObserverLinkedList<Color>

Properties

Type	Name	Summary
IEqualityComparer<Color>	EqualityComparer

CompositeDisposable

public class UniRx.CompositeDisposable
    : ICollection<IDisposable>, IEnumerable<IDisposable>, IEnumerable, IDisposable, ICancelable

Properties

Type	Name	Summary
Int32	Count	Gets the number of disposables contained in the CompositeDisposable.
Boolean	IsDisposed	Gets a value that indicates whether the object is disposed.
Boolean	IsReadOnly	Always returns false.

Methods

Type	Name	Summary
void	Add(IDisposable item)	Adds a disposable to the CompositeDisposable or disposes the disposable if the CompositeDisposable is disposed.
void	Clear()	Removes and disposes all disposables from the CompositeDisposable, but does not dispose the CompositeDisposable.
Boolean	Contains(IDisposable item)	Determines whether the CompositeDisposable contains a specific disposable.
void	CopyTo(IDisposable[] array, Int32 arrayIndex)	Copies the disposables contained in the CompositeDisposable to an array, starting at a particular array index.
void	Dispose()	Disposes all disposables in the group and removes them from the group.
IEnumerator<IDisposable>	GetEnumerator()	Returns an enumerator that iterates through the CompositeDisposable.
Boolean	Remove(IDisposable item)	Removes and disposes the first occurrence of a disposable from the CompositeDisposable.

CoroutineAsyncBridge

public class UniRx.CoroutineAsyncBridge
    : INotifyCompletion

Properties

Type	Name	Summary
Boolean	IsCompleted

Methods

Type	Name	Summary
void	GetResult()
void	OnCompleted(Action continuation)

Static Methods

Type	Name	Summary
CoroutineAsyncBridge	Start(T awaitTarget)

CoroutineAsyncBridge<T>

public class UniRx.CoroutineAsyncBridge<T>
    : INotifyCompletion

Properties

Type	Name	Summary
Boolean	IsCompleted

Methods

Type	Name	Summary
T	GetResult()
void	OnCompleted(Action continuation)

Static Methods

Type	Name	Summary
CoroutineAsyncBridge<T>	Start(T awaitTarget)

CoroutineAsyncExtensions

public static class UniRx.CoroutineAsyncExtensions

Static Methods

Type	Name	Summary
CoroutineAsyncBridge	GetAwaiter(this Coroutine coroutine)

CountChangedStatus

Event kind of CountNotifier.

public enum UniRx.CountChangedStatus
    : Enum, IComparable, IFormattable, IConvertible

Enum

Value	Name	Summary
0	Increment	Count incremented.
1	Decrement	Count decremented.
2	Empty	Count is zero.
3	Max	Count arrived max.

CountNotifier

Notify event of count flag.

public class UniRx.CountNotifier
    : IObservable<CountChangedStatus>

Properties

Type	Name	Summary
Int32	Count
Int32	Max

Methods

Type	Name	Summary
void	Decrement(Int32 decrementCount = 1)	Decrement count and notify status.
IDisposable	Increment(Int32 incrementCount = 1)	Increment count and notify status.
IDisposable	Subscribe(IObserver<CountChangedStatus> observer)	Subscribe observer.

DictionaryAddEvent<TKey, TValue>

public struct UniRx.DictionaryAddEvent<TKey, TValue>
    : IEquatable<DictionaryAddEvent<TKey, TValue>>

Properties

Type	Name	Summary
TKey	Key
TValue	Value

Methods

Type	Name	Summary
Boolean	Equals(DictionaryAddEvent<TKey, TValue> other)
Int32	GetHashCode()
String	ToString()

DictionaryDisposable<TKey, TValue>

public class UniRx.DictionaryDisposable<TKey, TValue>
    : IDisposable, IDictionary<TKey, TValue>, ICollection<KeyValuePair<TKey, TValue>>, IEnumerable<KeyValuePair<TKey, TValue>>, IEnumerable

Properties

Type	Name	Summary
Int32	Count
TValue	Item
KeyCollection<TKey, TValue>	Keys
ValueCollection<TKey, TValue>	Values

Methods

Type	Name	Summary
void	Add(TKey key, TValue value)
void	Clear()
Boolean	ContainsKey(TKey key)
void	Dispose()
Enumerator<TKey, TValue>	GetEnumerator()
void	GetObjectData(SerializationInfo info, StreamingContext context)
void	OnDeserialization(Object sender)
Boolean	Remove(TKey key)
Boolean	TryGetValue(TKey key, TValue& value)

DictionaryRemoveEvent<TKey, TValue>

public struct UniRx.DictionaryRemoveEvent<TKey, TValue>
    : IEquatable<DictionaryRemoveEvent<TKey, TValue>>

Properties

Type	Name	Summary
TKey	Key
TValue	Value

Methods

Type	Name	Summary
Boolean	Equals(DictionaryRemoveEvent<TKey, TValue> other)
Int32	GetHashCode()
String	ToString()

DictionaryReplaceEvent<TKey, TValue>

public struct UniRx.DictionaryReplaceEvent<TKey, TValue>
    : IEquatable<DictionaryReplaceEvent<TKey, TValue>>

Properties

Type	Name	Summary
TKey	Key
TValue	NewValue
TValue	OldValue

Methods

Type	Name	Summary
Boolean	Equals(DictionaryReplaceEvent<TKey, TValue> other)
Int32	GetHashCode()
String	ToString()

Disposable

public static class UniRx.Disposable

Static Fields

Type	Name	Summary
IDisposable	Empty

Static Methods

Type	Name	Summary
IDisposable	Create(Action disposeAction)
IDisposable	CreateWithState(TState state, Action<TState> disposeAction)

DisposableExtensions

public static class UniRx.DisposableExtensions

Static Methods

Type	Name	Summary
T	AddTo(this T disposable, ICollection<IDisposable> container)	Add disposable(self) to CompositeDisposable(or other ICollection). Return value is self disposable.
T	AddTo(this T disposable, GameObject gameObject)	Add disposable(self) to CompositeDisposable(or other ICollection). Return value is self disposable.
T	AddTo(this T disposable, Component gameObjectComponent)	Add disposable(self) to CompositeDisposable(or other ICollection). Return value is self disposable.
T	AddTo(this T disposable, ICollection<IDisposable> container, GameObject gameObject)	Add disposable(self) to CompositeDisposable(or other ICollection). Return value is self disposable.
T	AddTo(this T disposable, ICollection<IDisposable> container, Component gameObjectComponent)	Add disposable(self) to CompositeDisposable(or other ICollection). Return value is self disposable.

DoubleReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.DoubleReactiveProperty
    : ReactiveProperty<Double>, IReactiveProperty<Double>, IReadOnlyReactiveProperty<Double>, IObservable<Double>, IDisposable, IOptimizedObservable<Double>, IObserverLinkedList<Double>

EventPattern<TEventArgs>

Represents a .NET event invocation consisting of the weakly typed object that raised the event and the data that was generated by the event.

public class UniRx.EventPattern<TEventArgs>
    : EventPattern<Object, TEventArgs>, IEquatable<EventPattern<Object, TEventArgs>>, IEventPattern<Object, TEventArgs>

EventPattern<TSender, TEventArgs>

Represents a .NET event invocation consisting of the strongly typed object that raised the event and the data that was generated by the event.

public class UniRx.EventPattern<TSender, TEventArgs>
    : IEquatable<EventPattern<TSender, TEventArgs>>, IEventPattern<TSender, TEventArgs>

Properties

Type	Name	Summary
TEventArgs	EventArgs	Gets the event data that was generated by the event.
TSender	Sender	Gets the sender object that raised the event.

Methods

Type	Name	Summary
Boolean	Equals(EventPattern<TSender, TEventArgs> other)	Determines whether the current EventPattern<TSender, TEventArgs> object represents the same event as a specified EventPattern<TSender, TEventArgs> object.
Boolean	Equals(Object obj)	Determines whether the current EventPattern<TSender, TEventArgs> object represents the same event as a specified EventPattern<TSender, TEventArgs> object.
Int32	GetHashCode()	Returns the hash code for the current EventPattern<TSender, TEventArgs> instance.

FloatReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.FloatReactiveProperty
    : ReactiveProperty<Single>, IReactiveProperty<Single>, IReadOnlyReactiveProperty<Single>, IObservable<Single>, IDisposable, IOptimizedObservable<Single>, IObserverLinkedList<Single>

FrameCountType

public enum UniRx.FrameCountType
    : Enum, IComparable, IFormattable, IConvertible

Enum

Value	Name	Summary
0	Update
1	FixedUpdate
2	EndOfFrame

FrameCountTypeExtensions

public static class UniRx.FrameCountTypeExtensions

Static Methods

Type	Name	Summary
YieldInstruction	GetYieldInstruction(this FrameCountType frameCountType)

FrameInterval<T>

Represents a value associated with time interval information. The time interval can represent the time it took to produce the value, the interval relative to a previous value, the value's delivery time relative to a base, etc.

public struct UniRx.FrameInterval<T>
    : IEquatable<FrameInterval<T>>

Properties

Type	Name	Summary
Int32	Interval	Gets the interval.
T	Value	Gets the value.

Methods

Type	Name	Summary
Boolean	Equals(FrameInterval<T> other)	Determines whether the current FrameInterval<T> value has the same Value and Interval as a specified FrameInterval<T> value.
Boolean	Equals(Object obj)	Determines whether the current FrameInterval<T> value has the same Value and Interval as a specified FrameInterval<T> value.
Int32	GetHashCode()	Returns the hash code for the current FrameInterval<T> value.
String	ToString()	Returns a string representation of the current FrameInterval<T> value.

IAsyncMessageBroker

public interface UniRx.IAsyncMessageBroker
    : IAsyncMessagePublisher, IAsyncMessageReceiver

IAsyncMessagePublisher

public interface UniRx.IAsyncMessagePublisher

Methods

Type	Name	Summary
IObservable<Unit>	PublishAsync(T message)	Send Message to all receiver and await complete.

IAsyncMessageReceiver

public interface UniRx.IAsyncMessageReceiver

Methods

Type	Name	Summary
IDisposable	Subscribe(Func<T, IObservable<Unit>> asyncMessageReceiver)	Subscribe typed message.

IAsyncReactiveCommand<T>

public interface UniRx.IAsyncReactiveCommand<T>

Properties

Type	Name	Summary
IReadOnlyReactiveProperty<Boolean>	CanExecute

Methods

Type	Name	Summary
IDisposable	Execute(T parameter)
IDisposable	Subscribe(Func<T, IObservable<Unit>> asyncAction)
UniTask<T>	WaitUntilExecuteAsync()

ICancelable

public interface UniRx.ICancelable
    : IDisposable

Properties

Type	Name	Summary
Boolean	IsDisposed

IConnectableObservable<T>

public interface UniRx.IConnectableObservable<T>
    : IObservable<T>

Methods

Type	Name	Summary
IDisposable	Connect()

IEventPattern<TSender, TEventArgs>

Represents a .NET event invocation consisting of the strongly typed object that raised the event and the data that was generated by the event.

public interface UniRx.IEventPattern<TSender, TEventArgs>

Properties

Type	Name	Summary
TEventArgs	EventArgs	Gets the event data that was generated by the event.
TSender	Sender	Gets the sender object that raised the event.

IGroupedObservable<TKey, TElement>

public interface UniRx.IGroupedObservable<TKey, TElement>
    : IObservable<TElement>

Properties

Type	Name	Summary
TKey	Key

IMessageBroker

public interface UniRx.IMessageBroker
    : IMessagePublisher, IMessageReceiver

IMessagePublisher

public interface UniRx.IMessagePublisher

Methods

Type	Name	Summary
void	Publish(T message)	Send Message to all receiver.

IMessageReceiver

public interface UniRx.IMessageReceiver

Methods

Type	Name	Summary
IObservable<T>	Receive()	Subscribe typed message.

InspectorDisplayAttribute

public class UniRx.InspectorDisplayAttribute
    : PropertyAttribute, _Attribute

Properties

Type	Name	Summary
String	FieldName
Boolean	NotifyPropertyChanged

InspectorDisplayDrawer

public class UniRx.InspectorDisplayDrawer
    : PropertyDrawer

Methods

Type	Name	Summary
void	EmitPropertyField(Rect position, SerializedProperty targetSerializedProperty, GUIContent label)
Single	GetPropertyHeight(SerializedProperty property, GUIContent label)
void	OnGUI(Rect position, SerializedProperty property, GUIContent label)

IntReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.IntReactiveProperty
    : ReactiveProperty<Int32>, IReactiveProperty<Int32>, IReadOnlyReactiveProperty<Int32>, IObservable<Int32>, IDisposable, IOptimizedObservable<Int32>, IObserverLinkedList<Int32>

IObserver<TValue, TResult>

Provides a mechanism for receiving push-based notifications and returning a response.

public interface UniRx.IObserver<TValue, TResult>

Methods

Type	Name	Summary
TResult	OnCompleted()	Notifies the observer of the end of the sequence.
TResult	OnError(Exception exception)	Notifies the observer that an exception has occurred.
TResult	OnNext(TValue value)	Notifies the observer of a new element in the sequence.

IOptimizedObservable<T>

public interface UniRx.IOptimizedObservable<T>
    : IObservable<T>

Methods

Type	Name	Summary
Boolean	IsRequiredSubscribeOnCurrentThread()

IReactiveCollection<T>

public interface UniRx.IReactiveCollection<T>
    : IList<T>, ICollection<T>, IEnumerable<T>, IEnumerable, IReadOnlyReactiveCollection<T>

Properties

Type	Name	Summary
Int32	Count
T	Item

Methods

Type	Name	Summary
void	Move(Int32 oldIndex, Int32 newIndex)

IReactiveCommand<T>

public interface UniRx.IReactiveCommand<T>
    : IObservable<T>

Properties

Type	Name	Summary
IReadOnlyReactiveProperty<Boolean>	CanExecute

Methods

Type	Name	Summary
Boolean	Execute(T parameter)
UniTask<T>	WaitUntilExecuteAsync()

IReactiveDictionary<TKey, TValue>

public interface UniRx.IReactiveDictionary<TKey, TValue>
    : IReadOnlyReactiveDictionary<TKey, TValue>, IEnumerable<KeyValuePair<TKey, TValue>>, IEnumerable, IDictionary<TKey, TValue>, ICollection<KeyValuePair<TKey, TValue>>

IReactiveProperty<T>

public interface UniRx.IReactiveProperty<T>
    : IReadOnlyReactiveProperty<T>, IObservable<T>

Properties

Type	Name	Summary
T	Value

IReadOnlyReactiveCollection<T>

public interface UniRx.IReadOnlyReactiveCollection<T>
    : IEnumerable<T>, IEnumerable

Properties

Type	Name	Summary
Int32	Count
T	Item

Methods

Type	Name	Summary
IObservable<CollectionAddEvent<T>>	ObserveAdd()
IObservable<Int32>	ObserveCountChanged(Boolean notifyCurrentCount = False)
IObservable<CollectionMoveEvent<T>>	ObserveMove()
IObservable<CollectionRemoveEvent<T>>	ObserveRemove()
IObservable<CollectionReplaceEvent<T>>	ObserveReplace()
IObservable<Unit>	ObserveReset()

IReadOnlyReactiveDictionary<TKey, TValue>

public interface UniRx.IReadOnlyReactiveDictionary<TKey, TValue>
    : IEnumerable<KeyValuePair<TKey, TValue>>, IEnumerable

Properties

Type	Name	Summary
Int32	Count
TValue	Item

Methods

Type	Name	Summary
Boolean	ContainsKey(TKey key)
IObservable<DictionaryAddEvent<TKey, TValue>>	ObserveAdd()
IObservable<Int32>	ObserveCountChanged(Boolean notifyCurrentCount = False)
IObservable<DictionaryRemoveEvent<TKey, TValue>>	ObserveRemove()
IObservable<DictionaryReplaceEvent<TKey, TValue>>	ObserveReplace()
IObservable<Unit>	ObserveReset()
Boolean	TryGetValue(TKey key, TValue& value)

IReadOnlyReactiveProperty<T>

public interface UniRx.IReadOnlyReactiveProperty<T>
    : IObservable<T>

Properties

Type	Name	Summary
Boolean	HasValue
T	Value

Methods

Type	Name	Summary
UniTask<T>	WaitUntilValueChangedAsync()

IScheduler

public interface UniRx.IScheduler

Properties

Type	Name	Summary
DateTimeOffset	Now

Methods

Type	Name	Summary
IDisposable	Schedule(Action action)
IDisposable	Schedule(TimeSpan dueTime, Action action)

ISchedulerLongRunning

public interface UniRx.ISchedulerLongRunning

Methods

Type	Name	Summary
IDisposable	ScheduleLongRunning(Action<ICancelable> action)

ISchedulerPeriodic

public interface UniRx.ISchedulerPeriodic

Methods

Type	Name	Summary
IDisposable	SchedulePeriodic(TimeSpan period, Action action)

ISchedulerQueueing

public interface UniRx.ISchedulerQueueing

Methods

Type	Name	Summary
void	ScheduleQueueing(ICancelable cancel, T state, Action<T> action)

ISubject<T>

public interface UniRx.ISubject<T>
    : ISubject<T, T>, IObserver<T>, IObservable<T>

ISubject<TSource, TResult>

public interface UniRx.ISubject<TSource, TResult>
    : IObserver<TSource>, IObservable<TResult>

LongReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.LongReactiveProperty
    : ReactiveProperty<Int64>, IReactiveProperty<Int64>, IReadOnlyReactiveProperty<Int64>, IObservable<Int64>, IDisposable, IOptimizedObservable<Int64>, IObserverLinkedList<Int64>

MainThreadDispatcher

public class UniRx.MainThreadDispatcher
    : MonoBehaviour

Static Fields

Type	Name	Summary
CullingMode	cullingMode

Static Properties

Type	Name	Summary
String	InstanceName
Boolean	IsInitialized
Boolean	IsInMainThread

Static Methods

Type	Name	Summary
void	CullAllExcessDispatchers()
void	Initialize()
IObservable<Unit>	LateUpdateAsObservable()
IObservable<Boolean>	OnApplicationFocusAsObservable()
IObservable<Boolean>	OnApplicationPauseAsObservable()
IObservable<Unit>	OnApplicationQuitAsObservable()
void	Post(Action<Object> action, Object state)	Dispatch Asyncrhonous action.
void	RegisterUnhandledExceptionCallback(Action<Exception> exceptionCallback)
void	Send(Action<Object> action, Object state)	Dispatch Synchronous action if possible.
void	SendStartCoroutine(IEnumerator routine)	ThreadSafe StartCoroutine.
Coroutine	StartCoroutine(IEnumerator routine)
void	StartEndOfFrameMicroCoroutine(IEnumerator routine)
void	StartFixedUpdateMicroCoroutine(IEnumerator routine)
void	StartUpdateMicroCoroutine(IEnumerator routine)
void	UnsafeSend(Action action)	Run Synchronous action.
void	UnsafeSend(Action<T> action, T state)	Run Synchronous action.
IObservable<Unit>	UpdateAsObservable()

MainThreadDispatchType

public enum UniRx.MainThreadDispatchType
    : Enum, IComparable, IFormattable, IConvertible

Enum

Value	Name	Summary
0	Update	yield return null
1	FixedUpdate
2	EndOfFrame
3	GameObjectUpdate
4	LateUpdate

MessageBroker

In-Memory PubSub filtered by Type.

public class UniRx.MessageBroker
    : IMessageBroker, IMessagePublisher, IMessageReceiver, IDisposable

Methods

Type	Name	Summary
void	Dispose()
void	Publish(T message)
IObservable<T>	Receive()

Static Fields

Type	Name	Summary
IMessageBroker	Default	MessageBroker in Global scope.

MultilineReactivePropertyAttribute

Enables multiline input field for StringReactiveProperty. Default line is 3.

public class UniRx.MultilineReactivePropertyAttribute
    : PropertyAttribute, _Attribute

Properties

Type	Name	Summary
Int32	Lines

MultipleAssignmentDisposable

public class UniRx.MultipleAssignmentDisposable
    : IDisposable, ICancelable

Properties

Type	Name	Summary
IDisposable	Disposable
Boolean	IsDisposed

Methods

Type	Name	Summary
void	Dispose()

Notification

Provides a set of static methods for constructing notifications.

public static class UniRx.Notification

Static Methods

Type	Name	Summary
Notification<T>	CreateOnCompleted()	Creates an object that represents an OnCompleted notification to an observer.
Notification<T>	CreateOnError(Exception error)	Creates an object that represents an OnError notification to an observer.
Notification<T>	CreateOnNext(T value)	Creates an object that represents an OnNext notification to an observer.

Notification<T>

Represents a notification to an observer.

public abstract class UniRx.Notification<T>
    : IEquatable<Notification<T>>

Properties

Type	Name	Summary
Exception	Exception	Returns the exception of an OnError notification or returns null.
Boolean	HasValue	Returns a value that indicates whether the notification has a value.
NotificationKind	Kind	Gets the kind of notification that is represented.
T	Value	Returns the value of an OnNext notification or throws an exception.

Methods

Type	Name	Summary
void	Accept(IObserver<T> observer)	Invokes the observer's method corresponding to the notification.
TResult	Accept(IObserver<T, TResult> observer)	Invokes the observer's method corresponding to the notification.
void	Accept(Action<T> onNext, Action<Exception> onError, Action onCompleted)	Invokes the observer's method corresponding to the notification.
TResult	Accept(Func<T, TResult> onNext, Func<Exception, TResult> onError, Func<TResult> onCompleted)	Invokes the observer's method corresponding to the notification.
Boolean	Equals(Notification<T> other)	Determines whether the current Notification<T> object has the same observer message payload as a specified Notification<T> value.
Boolean	Equals(Object obj)	Determines whether the current Notification<T> object has the same observer message payload as a specified Notification<T> value.
IObservable<T>	ToObservable()	Returns an observable sequence with a single notification, using the immediate scheduler.
IObservable<T>	ToObservable(IScheduler scheduler)	Returns an observable sequence with a single notification, using the immediate scheduler.

NotificationKind

Indicates the type of a notification.

public enum UniRx.NotificationKind
    : Enum, IComparable, IFormattable, IConvertible

Enum

Value	Name	Summary
0	OnNext	Represents an OnNext notification.
1	OnError	Represents an OnError notification.
2	OnCompleted	Represents an OnCompleted notification.

Observable

public static class UniRx.Observable

Static Methods

Type	Name	Summary
IObservable<TSource>	Aggregate(this IObservable<TSource> source, Func<TSource, TSource, TSource> accumulator)
IObservable<TAccumulate>	Aggregate(this IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator)
IObservable<TResult>	Aggregate(this IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator, Func<TAccumulate, TResult> resultSelector)
IObservable<T>	Amb(IObservable1[]` sources)
IObservable<T>	Amb(IEnumerable<IObservable<T>> sources)
IObservable<T>	Amb(this IObservable<T> source, IObservable<T> second)
IObservable<T>	AsObservable(this IObservable<T> source)
IObservable<Unit>	AsSingleUnitObservable(this IObservable<T> source)	Same as LastOrDefault().AsUnitObservable().
IObservable<Unit>	AsUnitObservable(this IObservable<T> source)	Converting .Select(_ => Unit.Default) sequence.
IObservable<IList<T>>	BatchFrame(this IObservable<T> source)	Buffer elements in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).
IObservable<IList<T>>	BatchFrame(this IObservable<T> source, Int32 frameCount, FrameCountType frameCountType)	Buffer elements in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).
IObservable<Unit>	BatchFrame(this IObservable<Unit> source)	Buffer elements in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).
IObservable<Unit>	BatchFrame(this IObservable<Unit> source, Int32 frameCount, FrameCountType frameCountType)	Buffer elements in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).
IObservable<IList<T>>	Buffer(this IObservable<T> source, Int32 count)
IObservable<IList<T>>	Buffer(this IObservable<T> source, Int32 count, Int32 skip)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan, IScheduler scheduler)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan, Int32 count)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan, Int32 count, IScheduler scheduler)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan, TimeSpan timeShift)
IObservable<IList<T>>	Buffer(this IObservable<T> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)
IObservable<IList<TSource>>	Buffer(this IObservable<TSource> source, IObservable<TWindowBoundary> windowBoundaries)
IObservable<TResult>	Cast(this IObservable<TSource> source)	witness is for type inference.
IObservable<TResult>	Cast(this IObservable<TSource> source, TResult witness)	witness is for type inference.
IObservable<T>	Catch(this IObservable<T> source, Func<TException, IObservable<T>> errorHandler)
IObservable<TSource>	Catch(this IEnumerable<IObservable<TSource>> sources)
IObservable<TSource>	CatchIgnore(this IObservable<TSource> source)	Catch exception and return Observable.Empty.
IObservable<TSource>	CatchIgnore(this IObservable<TSource> source, Action<TException> errorAction)	Catch exception and return Observable.Empty.
IObservable<TResult>	CombineLatest(this IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, TRight, TResult> selector)
IObservable<IList<T>>	CombineLatest(this IEnumerable<IObservable<T>> sources)
IObservable<IList<TSource>>	CombineLatest(IObservable1[]` sources)
IObservable<TR>	CombineLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, CombineLatestFunc<T1, T2, T3, TR> resultSelector)
IObservable<TR>	CombineLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, CombineLatestFunc<T1, T2, T3, T4, TR> resultSelector)
IObservable<TR>	CombineLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, CombineLatestFunc<T1, T2, T3, T4, T5, TR> resultSelector)
IObservable<TR>	CombineLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, CombineLatestFunc<T1, T2, T3, T4, T5, T6, TR> resultSelector)
IObservable<TR>	CombineLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, CombineLatestFunc<T1, T2, T3, T4, T5, T6, T7, TR> resultSelector)
IObservable<TSource>	Concat(IObservable1[]` sources)
IObservable<TSource>	Concat(this IEnumerable<IObservable<TSource>> sources)
IObservable<TSource>	Concat(this IObservable<IObservable<TSource>> sources)
IObservable<TSource>	Concat(this IObservable<TSource> first, IObservable1[]` seconds)
IObservable<TR>	ContinueWith(this IObservable<T> source, IObservable<TR> other)	Lightweight SelectMany for Single Async Operation.
IObservable<TR>	ContinueWith(this IObservable<T> source, Func<T, IObservable<TR>> selector)	Lightweight SelectMany for Single Async Operation.
IObservable<T>	Create(Func<IObserver<T>, IDisposable> subscribe)	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.
IObservable<T>	Create(Func<IObserver<T>, IDisposable> subscribe, Boolean isRequiredSubscribeOnCurrentThread)	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.
IObservable<T>	CreateSafe(Func<IObserver<T>, IDisposable> subscribe)	Create anonymous observable. Safe means auto detach when error raised in onNext pipeline. This is recommended for make generator (ColdObservable).
IObservable<T>	CreateSafe(Func<IObserver<T>, IDisposable> subscribe, Boolean isRequiredSubscribeOnCurrentThread)	Create anonymous observable. Safe means auto detach when error raised in onNext pipeline. This is recommended for make generator (ColdObservable).
IObservable<T>	CreateWithState(TState state, Func<TState, IObserver<T>, IDisposable> subscribe)	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.
IObservable<T>	CreateWithState(TState state, Func<TState, IObserver<T>, IDisposable> subscribe, Boolean isRequiredSubscribeOnCurrentThread)	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.
IObservable<T>	DefaultIfEmpty(this IObservable<T> source)
IObservable<T>	DefaultIfEmpty(this IObservable<T> source, T defaultValue)
IObservable<T>	Defer(Func<IObservable<T>> observableFactory)
IObservable<T>	Delay(this IObservable<T> source, TimeSpan dueTime)
IObservable<TSource>	Delay(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
IObservable<T>	DelayFrame(this IObservable<T> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<T>	DelayFrameSubscription(this IObservable<T> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<T>	DelaySubscription(this IObservable<T> source, TimeSpan dueTime)
IObservable<T>	DelaySubscription(this IObservable<T> source, TimeSpan dueTime, IScheduler scheduler)
IObservable<T>	DelaySubscription(this IObservable<T> source, DateTimeOffset dueTime)
IObservable<T>	DelaySubscription(this IObservable<T> source, DateTimeOffset dueTime, IScheduler scheduler)
IObservable<T>	Dematerialize(this IObservable<Notification<T>> source)
IObservable<TSource>	Distinct(this IObservable<TSource> source)
IObservable<TSource>	Distinct(this IObservable<TSource> source, IEqualityComparer<TSource> comparer)
IObservable<TSource>	Distinct(this IObservable<TSource> source, Func<TSource, TKey> keySelector)
IObservable<TSource>	Distinct(this IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
IObservable<T>	DistinctUntilChanged(this IObservable<T> source)
IObservable<T>	DistinctUntilChanged(this IObservable<T> source, IEqualityComparer<T> comparer)
IObservable<T>	DistinctUntilChanged(this IObservable<T> source, Func<T, TKey> keySelector)
IObservable<T>	DistinctUntilChanged(this IObservable<T> source, Func<T, TKey> keySelector, IEqualityComparer<TKey> comparer)
IObservable<T>	Do(this IObservable<T> source, IObserver<T> observer)
IObservable<T>	Do(this IObservable<T> source, Action<T> onNext)
IObservable<T>	Do(this IObservable<T> source, Action<T> onNext, Action<Exception> onError)
IObservable<T>	Do(this IObservable<T> source, Action<T> onNext, Action onCompleted)
IObservable<T>	Do(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, Action onCompleted)
IObservable<T>	DoOnCancel(this IObservable<T> source, Action onCancel)
IObservable<T>	DoOnCompleted(this IObservable<T> source, Action onCompleted)
IObservable<T>	DoOnError(this IObservable<T> source, Action<Exception> onError)
IObservable<T>	DoOnSubscribe(this IObservable<T> source, Action onSubscribe)
IObservable<T>	DoOnTerminate(this IObservable<T> source, Action onTerminate)
IObservable<T>	Empty()	Empty Observable. Returns only OnCompleted.
IObservable<T>	Empty(IScheduler scheduler)	Empty Observable. Returns only OnCompleted.
IObservable<T>	Empty(T witness)	Empty Observable. Returns only OnCompleted.
IObservable<T>	Empty(IScheduler scheduler, T witness)	Empty Observable. Returns only OnCompleted.
IObservable<Boolean>	EveryApplicationFocus()
IObservable<Boolean>	EveryApplicationPause()
IObservable<Int64>	EveryEndOfFrame()
IObservable<Int64>	EveryFixedUpdate()
IObservable<Int64>	EveryGameObjectUpdate()	EveryGameObjectUpdate calls from MainThreadDispatcher's Update.
IObservable<Int64>	EveryLateUpdate()	EveryLateUpdate calls from MainThreadDispatcher's OnLateUpdate.
IObservable<Int64>	EveryUpdate()	EveryUpdate calls coroutine's yield return null timing. It is after all Update and before LateUpdate.
IObservable<T>	Finally(this IObservable<T> source, Action finallyAction)
IObservable<T>	First(this IObservable<T> source)
IObservable<T>	First(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	FirstOrDefault(this IObservable<T> source)
IObservable<T>	FirstOrDefault(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<Unit>	ForEachAsync(this IObservable<T> source, Action<T> onNext)
IObservable<Unit>	ForEachAsync(this IObservable<T> source, Action<T, Int32> onNext)
IObservable<FrameInterval<T>>	FrameInterval(this IObservable<T> source)
IObservable<TimeInterval<T>>	FrameTimeInterval(this IObservable<T> source, Boolean ignoreTimeScale = False)
Func<IObservable<TResult>>	FromAsyncPattern(Func<AsyncCallback, Object, IAsyncResult> begin, Func<IAsyncResult, TResult> end)
Func<T1, IObservable<TResult>>	FromAsyncPattern(Func<T1, AsyncCallback, Object, IAsyncResult> begin, Func<IAsyncResult, TResult> end)
Func<T1, T2, IObservable<TResult>>	FromAsyncPattern(Func<T1, T2, AsyncCallback, Object, IAsyncResult> begin, Func<IAsyncResult, TResult> end)
Func<IObservable<Unit>>	FromAsyncPattern(Func<AsyncCallback, Object, IAsyncResult> begin, Action<IAsyncResult> end)
Func<T1, IObservable<Unit>>	FromAsyncPattern(Func<T1, AsyncCallback, Object, IAsyncResult> begin, Action<IAsyncResult> end)
Func<T1, T2, IObservable<Unit>>	FromAsyncPattern(Func<T1, T2, AsyncCallback, Object, IAsyncResult> begin, Action<IAsyncResult> end)
IObservable<Unit>	FromCoroutine(Func<IEnumerator> coroutine, Boolean publishEveryYield = False)	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<Unit>	FromCoroutine(Func<CancellationToken, IEnumerator> coroutine, Boolean publishEveryYield = False)	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<T>	FromCoroutine(Func<IObserver<T>, IEnumerator> coroutine)	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<T>	FromCoroutine(Func<IObserver<T>, CancellationToken, IEnumerator> coroutine)	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<T>	FromCoroutineValue(Func<IEnumerator> coroutine, Boolean nullAsNextUpdate = True)	Convert coroutine to typed IObservable. If nullAsNextUpdate = true then yield return null when Enumerator.Current and no null publish observer.OnNext.
IObservable<T>	FromCoroutineValue(Func<CancellationToken, IEnumerator> coroutine, Boolean nullAsNextUpdate = True)	Convert coroutine to typed IObservable. If nullAsNextUpdate = true then yield return null when Enumerator.Current and no null publish observer.OnNext.
IObservable<Unit>	FromEvent(Func<Action, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler)
IObservable<TEventArgs>	FromEvent(Func<Action<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler)
IObservable<Unit>	FromEvent(Action<Action> addHandler, Action<Action> removeHandler)
IObservable<T>	FromEvent(Action<Action<T>> addHandler, Action<Action<T>> removeHandler)
IObservable<EventPattern<TEventArgs>>	FromEventPattern(Func<EventHandler<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler)
IObservable<Unit>	FromMicroCoroutine(Func<IEnumerator> coroutine, Boolean publishEveryYield = False, FrameCountType frameCountType = Update)	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<Unit>	FromMicroCoroutine(Func<CancellationToken, IEnumerator> coroutine, Boolean publishEveryYield = False, FrameCountType frameCountType = Update)	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<T>	FromMicroCoroutine(Func<IObserver<T>, IEnumerator> coroutine, FrameCountType frameCountType = Update)	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
IObservable<T>	FromMicroCoroutine(Func<IObserver<T>, CancellationToken, IEnumerator> coroutine, FrameCountType frameCountType = Update)	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.
AsyncSubject<TSource>	GetAwaiter(this IObservable<TSource> source)	Gets an awaiter that returns the last value of the observable sequence or throws an exception if the sequence is empty. This operation subscribes to the observable sequence, making it hot.
AsyncSubject<TSource>	GetAwaiter(this IConnectableObservable<TSource> source)	Gets an awaiter that returns the last value of the observable sequence or throws an exception if the sequence is empty. This operation subscribes to the observable sequence, making it hot.
AsyncSubject<TSource>	GetAwaiter(this IObservable<TSource> source, CancellationToken cancellationToken)	Gets an awaiter that returns the last value of the observable sequence or throws an exception if the sequence is empty. This operation subscribes to the observable sequence, making it hot.
AsyncSubject<TSource>	GetAwaiter(this IConnectableObservable<TSource> source, CancellationToken cancellationToken)	Gets an awaiter that returns the last value of the observable sequence or throws an exception if the sequence is empty. This operation subscribes to the observable sequence, making it hot.
IObservable<IGroupedObservable<TKey, TSource>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector)
IObservable<IGroupedObservable<TKey, TSource>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
IObservable<IGroupedObservable<TKey, TElement>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector)
IObservable<IGroupedObservable<TKey, TElement>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer)
IObservable<IGroupedObservable<TKey, TSource>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Int32 capacity)
IObservable<IGroupedObservable<TKey, TSource>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Int32 capacity, IEqualityComparer<TKey> comparer)
IObservable<IGroupedObservable<TKey, TElement>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Int32 capacity)
IObservable<IGroupedObservable<TKey, TElement>>	GroupBy(this IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Int32 capacity, IEqualityComparer<TKey> comparer)
IObservable<T>	IgnoreElements(this IObservable<T> source)
IObservable<Int64>	Interval(TimeSpan period)
IObservable<Int64>	Interval(TimeSpan period, IScheduler scheduler)
IObservable<Int64>	IntervalFrame(Int32 intervalFrameCount, FrameCountType frameCountType = Update)
IObservable<T>	Last(this IObservable<T> source)
IObservable<T>	Last(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	LastOrDefault(this IObservable<T> source)
IObservable<T>	LastOrDefault(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<Notification<T>>	Materialize(this IObservable<T> source)
IObservable<TSource>	Merge(this IEnumerable<IObservable<TSource>> sources)
IObservable<TSource>	Merge(this IEnumerable<IObservable<TSource>> sources, IScheduler scheduler)
IObservable<TSource>	Merge(this IEnumerable<IObservable<TSource>> sources, Int32 maxConcurrent)
IObservable<TSource>	Merge(this IEnumerable<IObservable<TSource>> sources, Int32 maxConcurrent, IScheduler scheduler)
IObservable<TSource>	Merge(IObservable1[]` sources)
IObservable<TSource>	Merge(IScheduler scheduler, IObservable1[]` sources)
IObservable<T>	Merge(this IObservable<T> first, IObservable1[]` seconds)
IObservable<T>	Merge(this IObservable<T> first, IObservable<T> second, IScheduler scheduler)
IObservable<T>	Merge(this IObservable<IObservable<T>> sources)
IObservable<T>	Merge(this IObservable<IObservable<T>> sources, Int32 maxConcurrent)
IConnectableObservable<T>	Multicast(this IObservable<T> source, ISubject<T> subject)
IObservable<T>	Never()	Non-Terminating Observable. It's no returns, never finish.
IObservable<T>	Never(T witness)	Non-Terminating Observable. It's no returns, never finish.
IObservable<Unit>	NextFrame(FrameCountType frameCountType = Update)
IObservable<T>	ObserveOn(this IObservable<T> source, IScheduler scheduler)
IObservable<T>	ObserveOnMainThread(this IObservable<T> source)
IObservable<T>	ObserveOnMainThread(this IObservable<T> source, MainThreadDispatchType dispatchType)
IObservable<TResult>	OfType(this IObservable<TSource> source)	witness is for type inference.
IObservable<TResult>	OfType(this IObservable<TSource> source, TResult witness)	witness is for type inference.
IObservable<Unit>	OnceApplicationQuit()	publish OnNext(Unit) and OnCompleted() on application quit.
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source, Action<TException> onError)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source, Action<TException> onError, TimeSpan delay)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source, Action<TException> onError, Int32 retryCount)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source, Action<TException> onError, Int32 retryCount, TimeSpan delay)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<TSource>	OnErrorRetry(this IObservable<TSource> source, Action<TException> onError, Int32 retryCount, TimeSpan delay, IScheduler delayScheduler)	Repeats the source observable sequence until it successfully terminates. This is same as Retry().
IObservable<Pair<T>>	Pairwise(this IObservable<T> source)	Projects old and new element of a sequence into a new form.
IObservable<TR>	Pairwise(this IObservable<T> source, Func<T, T, TR> selector)	Projects old and new element of a sequence into a new form.
IConnectableObservable<T>	Publish(this IObservable<T> source)
IConnectableObservable<T>	Publish(this IObservable<T> source, T initialValue)
IConnectableObservable<T>	PublishLast(this IObservable<T> source)
IObservable<Int32>	Range(Int32 start, Int32 count)
IObservable<Int32>	Range(Int32 start, Int32 count, IScheduler scheduler)
IObservable<T>	RefCount(this IConnectableObservable<T> source)
IObservable<T>	Repeat(T value)
IObservable<T>	Repeat(T value, IScheduler scheduler)
IObservable<T>	Repeat(T value, Int32 repeatCount)
IObservable<T>	Repeat(T value, Int32 repeatCount, IScheduler scheduler)
IObservable<T>	Repeat(this IObservable<T> source)
IObservable<T>	RepeatSafe(this IObservable<T> source)	Same as Repeat() but if arriving contiguous "OnComplete" Repeat stops.
IObservable<T>	RepeatUntilDestroy(this IObservable<T> source, GameObject target)
IObservable<T>	RepeatUntilDestroy(this IObservable<T> source, Component target)
IObservable<T>	RepeatUntilDisable(this IObservable<T> source, GameObject target)
IObservable<T>	RepeatUntilDisable(this IObservable<T> source, Component target)
IConnectableObservable<T>	Replay(this IObservable<T> source)
IConnectableObservable<T>	Replay(this IObservable<T> source, IScheduler scheduler)
IConnectableObservable<T>	Replay(this IObservable<T> source, Int32 bufferSize)
IConnectableObservable<T>	Replay(this IObservable<T> source, Int32 bufferSize, IScheduler scheduler)
IConnectableObservable<T>	Replay(this IObservable<T> source, TimeSpan window)
IConnectableObservable<T>	Replay(this IObservable<T> source, TimeSpan window, IScheduler scheduler)
IConnectableObservable<T>	Replay(this IObservable<T> source, Int32 bufferSize, TimeSpan window, IScheduler scheduler)
IObservable<TSource>	Retry(this IObservable<TSource> source)
IObservable<TSource>	Retry(this IObservable<TSource> source, Int32 retryCount)
IObservable<T>	Return(T value)	Return single sequence Immediately.
IObservable<T>	Return(T value, IScheduler scheduler)	Return single sequence Immediately.
IObservable<Unit>	Return(Unit value)	Return single sequence Immediately.
IObservable<Boolean>	Return(Boolean value)	Return single sequence Immediately.
IObservable<Int32>	Return(Int32 value)	Return single sequence Immediately.
IObservable<Unit>	ReturnUnit()	Same as Observable.Return(Unit.Default); but no allocate memory.
IObservable<T>	Sample(this IObservable<T> source, TimeSpan interval)
IObservable<T>	Sample(this IObservable<T> source, TimeSpan interval, IScheduler scheduler)
IObservable<T>	Sample(this IObservable<T> source, IObservable<T2> sampler)
IObservable<T>	SampleFrame(this IObservable<T> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<TSource>	Scan(this IObservable<TSource> source, Func<TSource, TSource, TSource> accumulator)
IObservable<TAccumulate>	Scan(this IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator)
IObservable<TR>	Select(this IObservable<T> source, Func<T, TR> selector)
IObservable<TR>	Select(this IObservable<T> source, Func<T, Int32, TR> selector)
IObservable<Unit>	SelectMany(this IObservable<T> source, IEnumerator coroutine, Boolean publishEveryYield = False)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<Unit>	SelectMany(this IObservable<T> source, Func<IEnumerator> selector, Boolean publishEveryYield = False)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<Unit>	SelectMany(this IObservable<T> source, Func<T, IEnumerator> selector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, Int32, IEnumerable<TCollection>> collectionSelector, Func<TSource, Int32, TCollection, Int32, TResult> resultSelector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TR>	SelectMany(this IObservable<T> source, IObservable<TR> other)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TR>	SelectMany(this IObservable<T> source, Func<T, IObservable<TR>> selector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, Int32, IObservable<TResult>> selector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TR>	SelectMany(this IObservable<T> source, Func<T, IObservable<TC>> collectionSelector, Func<T, TC, TR> resultSelector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, Int32, IObservable<TCollection>> collectionSelector, Func<TSource, Int32, TCollection, Int32, TResult> resultSelector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, IEnumerable<TResult>> selector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, Int32, IEnumerable<TResult>> selector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<TResult>	SelectMany(this IObservable<TSource> source, Func<TSource, IEnumerable<TCollection>> collectionSelector, Func<TSource, TCollection, TResult> resultSelector)	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.
IObservable<T>	Share(this IObservable<T> source)	same as Publish().RefCount()
IObservable<T>	Single(this IObservable<T> source)
IObservable<T>	Single(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	SingleOrDefault(this IObservable<T> source)
IObservable<T>	SingleOrDefault(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	Skip(this IObservable<T> source, Int32 count)
IObservable<T>	Skip(this IObservable<T> source, TimeSpan duration)
IObservable<T>	Skip(this IObservable<T> source, TimeSpan duration, IScheduler scheduler)
IObservable<T>	SkipUntil(this IObservable<T> source, IObservable<TOther> other)
IObservable<T>	SkipWhile(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	SkipWhile(this IObservable<T> source, Func<T, Int32, Boolean> predicate)
IObservable<T>	Start(Func<T> function)
IObservable<T>	Start(Func<T> function, TimeSpan timeSpan)
IObservable<T>	Start(Func<T> function, IScheduler scheduler)
IObservable<T>	Start(Func<T> function, TimeSpan timeSpan, IScheduler scheduler)
IObservable<Unit>	Start(Action action)
IObservable<Unit>	Start(Action action, TimeSpan timeSpan)
IObservable<Unit>	Start(Action action, IScheduler scheduler)
IObservable<Unit>	Start(Action action, TimeSpan timeSpan, IScheduler scheduler)
Coroutine	StartAsCoroutine(this IObservable<T> source, CancellationToken cancel = null)	AutoStart observable as coroutine.
Coroutine	StartAsCoroutine(this IObservable<T> source, Action<T> onResult, CancellationToken cancel = null)	AutoStart observable as coroutine.
Coroutine	StartAsCoroutine(this IObservable<T> source, Action<Exception> onError, CancellationToken cancel = null)	AutoStart observable as coroutine.
Coroutine	StartAsCoroutine(this IObservable<T> source, Action<T> onResult, Action<Exception> onError, CancellationToken cancel = null)	AutoStart observable as coroutine.
IObservable<T>	StartWith(this IObservable<T> source, T value)
IObservable<T>	StartWith(this IObservable<T> source, Func<T> valueFactory)
IObservable<T>	StartWith(this IObservable<T> source, T[] values)
IObservable<T>	StartWith(this IObservable<T> source, IEnumerable<T> values)
IObservable<T>	StartWith(this IObservable<T> source, IScheduler scheduler, T value)
IObservable<T>	StartWith(this IObservable<T> source, IScheduler scheduler, IEnumerable<T> values)
IObservable<T>	StartWith(this IObservable<T> source, IScheduler scheduler, T[] values)
IObservable<T>	SubscribeOn(this IObservable<T> source, IScheduler scheduler)
IObservable<T>	SubscribeOnMainThread(this IObservable<T> source)
IObservable<T>	Switch(this IObservable<IObservable<T>> sources)
IObservable<T>	Synchronize(this IObservable<T> source)
IObservable<T>	Synchronize(this IObservable<T> source, Object gate)
IObservable<T>	Take(this IObservable<T> source, Int32 count)
IObservable<T>	Take(this IObservable<T> source, TimeSpan duration)
IObservable<T>	Take(this IObservable<T> source, TimeSpan duration, IScheduler scheduler)
IObservable<T>	TakeLast(this IObservable<T> source, Int32 count)
IObservable<T>	TakeLast(this IObservable<T> source, TimeSpan duration)
IObservable<T>	TakeLast(this IObservable<T> source, TimeSpan duration, IScheduler scheduler)
IObservable<T>	TakeUntil(this IObservable<T> source, IObservable<TOther> other)
IObservable<T>	TakeUntilDestroy(this IObservable<T> source, Component target)
IObservable<T>	TakeUntilDestroy(this IObservable<T> source, GameObject target)
IObservable<T>	TakeUntilDisable(this IObservable<T> source, Component target)
IObservable<T>	TakeUntilDisable(this IObservable<T> source, GameObject target)
IObservable<T>	TakeWhile(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	TakeWhile(this IObservable<T> source, Func<T, Int32, Boolean> predicate)
IObservable<TSource>	Throttle(this IObservable<TSource> source, TimeSpan dueTime)
IObservable<TSource>	Throttle(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
IObservable<TSource>	ThrottleFirst(this IObservable<TSource> source, TimeSpan dueTime)
IObservable<TSource>	ThrottleFirst(this IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler)
IObservable<TSource>	ThrottleFirstFrame(this IObservable<TSource> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<TSource>	ThrottleFrame(this IObservable<TSource> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<T>	Throw(Exception error)	Empty Observable. Returns only onError.
IObservable<T>	Throw(Exception error, T witness)	Empty Observable. Returns only onError.
IObservable<T>	Throw(Exception error, IScheduler scheduler)	Empty Observable. Returns only onError.
IObservable<T>	Throw(Exception error, IScheduler scheduler, T witness)	Empty Observable. Returns only onError.
IObservable<TimeInterval<TSource>>	TimeInterval(this IObservable<TSource> source)
IObservable<TimeInterval<TSource>>	TimeInterval(this IObservable<TSource> source, IScheduler scheduler)
IObservable<T>	Timeout(this IObservable<T> source, TimeSpan dueTime)
IObservable<T>	Timeout(this IObservable<T> source, TimeSpan dueTime, IScheduler scheduler)
IObservable<T>	Timeout(this IObservable<T> source, DateTimeOffset dueTime)
IObservable<T>	Timeout(this IObservable<T> source, DateTimeOffset dueTime, IScheduler scheduler)
IObservable<T>	TimeoutFrame(this IObservable<T> source, Int32 frameCount, FrameCountType frameCountType = Update)
IObservable<Int64>	Timer(TimeSpan dueTime, TimeSpan period, IScheduler scheduler)
IObservable<Int64>	Timer(DateTimeOffset dueTime, TimeSpan period, IScheduler scheduler)
IObservable<Int64>	Timer(TimeSpan dueTime)
IObservable<Int64>	Timer(DateTimeOffset dueTime)
IObservable<Int64>	Timer(TimeSpan dueTime, TimeSpan period)
IObservable<Int64>	Timer(DateTimeOffset dueTime, TimeSpan period)
IObservable<Int64>	Timer(TimeSpan dueTime, IScheduler scheduler)
IObservable<Int64>	Timer(DateTimeOffset dueTime, IScheduler scheduler)
IObservable<Int64>	TimerFrame(Int32 dueTimeFrameCount, FrameCountType frameCountType = Update)
IObservable<Int64>	TimerFrame(Int32 dueTimeFrameCount, Int32 periodFrameCount, FrameCountType frameCountType = Update)
IObservable<Timestamped<TSource>>	Timestamp(this IObservable<TSource> source)
IObservable<Timestamped<TSource>>	Timestamp(this IObservable<TSource> source, IScheduler scheduler)
IObservable<T[]>	ToArray(this IObservable<T> source)
Func<IObservable<T>>	ToAsync(Func<T> function)
Func<IObservable<T>>	ToAsync(Func<T> function, IScheduler scheduler)
Func<IObservable<Unit>>	ToAsync(Action action)
Func<IObservable<Unit>>	ToAsync(Action action, IScheduler scheduler)
IEnumerator	ToAwaitableEnumerator(this IObservable<T> source, CancellationToken cancel = null)	Convert to awaitable IEnumerator.
IEnumerator	ToAwaitableEnumerator(this IObservable<T> source, Action<T> onResult, CancellationToken cancel = null)	Convert to awaitable IEnumerator.
IEnumerator	ToAwaitableEnumerator(this IObservable<T> source, Action<Exception> onError, CancellationToken cancel = null)	Convert to awaitable IEnumerator.
IEnumerator	ToAwaitableEnumerator(this IObservable<T> source, Action<T> onResult, Action<Exception> onError, CancellationToken cancel = null)	Convert to awaitable IEnumerator.
IObservable<IList<T>>	ToList(this IObservable<T> source)
IObservable<Unit>	ToObservable(this IEnumerator coroutine, Boolean publishEveryYield = False)
IObservable<T>	ToObservable(this IEnumerable<T> source)
IObservable<T>	ToObservable(this IEnumerable<T> source, IScheduler scheduler)
ObservableYieldInstruction<T>	ToYieldInstruction(this IObservable<T> source, CancellationToken cancel)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<T>	ToYieldInstruction(this IObservable<T> source, Boolean throwOnError)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<T>	ToYieldInstruction(this IObservable<T> source, Boolean throwOnError, CancellationToken cancel)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<Unit>	ToYieldInstruction(this IEnumerator coroutine)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<Unit>	ToYieldInstruction(this IEnumerator coroutine, Boolean throwOnError)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<Unit>	ToYieldInstruction(this IEnumerator coroutine, CancellationToken cancellationToken)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<Unit>	ToYieldInstruction(this IEnumerator coroutine, Boolean throwOnError, CancellationToken cancellationToken)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
ObservableYieldInstruction<T>	ToYieldInstruction(this IObservable<T> source)	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).
T	Wait(this IObservable<T> source)
T	Wait(this IObservable<T> source, TimeSpan timeout)
IObservable<T[]>	WhenAll(IObservable1[]` sources)	Specialized for single async operations like Task.WhenAll, Zip.Take(1). If sequence is empty, return T[0] array.
IObservable<Unit>	WhenAll(IObservable1[]` sources)	Specialized for single async operations like Task.WhenAll, Zip.Take(1). If sequence is empty, return T[0] array.
IObservable<T[]>	WhenAll(this IEnumerable<IObservable<T>> sources)	Specialized for single async operations like Task.WhenAll, Zip.Take(1). If sequence is empty, return T[0] array.
IObservable<Unit>	WhenAll(this IEnumerable<IObservable<Unit>> sources)	Specialized for single async operations like Task.WhenAll, Zip.Take(1). If sequence is empty, return T[0] array.
IObservable<T>	Where(this IObservable<T> source, Func<T, Boolean> predicate)
IObservable<T>	Where(this IObservable<T> source, Func<T, Int32, Boolean> predicate)
IObservable<TResult>	WithLatestFrom(this IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, TRight, TResult> selector)
IObservable<TR>	Zip(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, ZipFunc<T1, T2, T3, T4, T5, T6, T7, TR> resultSelector)
IObservable<TResult>	Zip(this IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, TRight, TResult> selector)
IObservable<IList<T>>	Zip(this IEnumerable<IObservable<T>> sources)
IObservable<IList<T>>	Zip(IObservable1[]` sources)
IObservable<TR>	Zip(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, ZipFunc<T1, T2, T3, TR> resultSelector)
IObservable<TR>	Zip(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, ZipFunc<T1, T2, T3, T4, TR> resultSelector)
IObservable<TR>	Zip(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, ZipFunc<T1, T2, T3, T4, T5, TR> resultSelector)
IObservable<TR>	Zip(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, ZipFunc<T1, T2, T3, T4, T5, T6, TR> resultSelector)
IObservable<TResult>	ZipLatest(this IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, TRight, TResult> selector)
IObservable<IList<T>>	ZipLatest(this IEnumerable<IObservable<T>> sources)
IObservable<IList<TSource>>	ZipLatest(IObservable1[]` sources)
IObservable<TR>	ZipLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, ZipLatestFunc<T1, T2, T3, TR> resultSelector)
IObservable<TR>	ZipLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, ZipLatestFunc<T1, T2, T3, T4, TR> resultSelector)
IObservable<TR>	ZipLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, ZipLatestFunc<T1, T2, T3, T4, T5, TR> resultSelector)
IObservable<TR>	ZipLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, ZipLatestFunc<T1, T2, T3, T4, T5, T6, TR> resultSelector)
IObservable<TR>	ZipLatest(this IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, ZipLatestFunc<T1, T2, T3, T4, T5, T6, T7, TR> resultSelector)

ObservableExtensions

public static class UniRx.ObservableExtensions

Static Methods

Type	Name	Summary
IDisposable	Subscribe(this IObservable<T> source)
IDisposable	Subscribe(this IObservable<T> source, Action<T> onNext)
IDisposable	Subscribe(this IObservable<T> source, Action<T> onNext, Action<Exception> onError)
IDisposable	Subscribe(this IObservable<T> source, Action<T> onNext, Action onCompleted)
IDisposable	Subscribe(this IObservable<T> source, Action<T> onNext, Action<Exception> onError, Action onCompleted)
IDisposable	SubscribeWithState(this IObservable<T> source, TState state, Action<T, TState> onNext)
IDisposable	SubscribeWithState(this IObservable<T> source, TState state, Action<T, TState> onNext, Action<Exception, TState> onError)
IDisposable	SubscribeWithState(this IObservable<T> source, TState state, Action<T, TState> onNext, Action<TState> onCompleted)
IDisposable	SubscribeWithState(this IObservable<T> source, TState state, Action<T, TState> onNext, Action<Exception, TState> onError, Action<TState> onCompleted)
IDisposable	SubscribeWithState2(this IObservable<T> source, TState1 state1, TState2 state2, Action<T, TState1, TState2> onNext)
IDisposable	SubscribeWithState2(this IObservable<T> source, TState1 state1, TState2 state2, Action<T, TState1, TState2> onNext, Action<Exception, TState1, TState2> onError)
IDisposable	SubscribeWithState2(this IObservable<T> source, TState1 state1, TState2 state2, Action<T, TState1, TState2> onNext, Action<TState1, TState2> onCompleted)
IDisposable	SubscribeWithState2(this IObservable<T> source, TState1 state1, TState2 state2, Action<T, TState1, TState2> onNext, Action<Exception, TState1, TState2> onError, Action<TState1, TState2> onCompleted)
IDisposable	SubscribeWithState3(this IObservable<T> source, TState1 state1, TState2 state2, TState3 state3, Action<T, TState1, TState2, TState3> onNext)
IDisposable	SubscribeWithState3(this IObservable<T> source, TState1 state1, TState2 state2, TState3 state3, Action<T, TState1, TState2, TState3> onNext, Action<Exception, TState1, TState2, TState3> onError)
IDisposable	SubscribeWithState3(this IObservable<T> source, TState1 state1, TState2 state2, TState3 state3, Action<T, TState1, TState2, TState3> onNext, Action<TState1, TState2, TState3> onCompleted)
IDisposable	SubscribeWithState3(this IObservable<T> source, TState1 state1, TState2 state2, TState3 state3, Action<T, TState1, TState2, TState3> onNext, Action<Exception, TState1, TState2, TState3> onError, Action<TState1, TState2, TState3> onCompleted)

ObservableWWW

public static class UniRx.ObservableWWW

Static Methods

Type	Name	Summary
IObservable<String>	Get(String url, Dictionary<String, String> headers = null, IProgress<Single> progress = null)
IObservable<Byte[]>	GetAndGetBytes(String url, Dictionary<String, String> headers = null, IProgress<Single> progress = null)
IObservable<WWW>	GetWWW(String url, Dictionary<String, String> headers = null, IProgress<Single> progress = null)
IObservable<AssetBundle>	LoadFromCacheOrDownload(String url, Int32 version, IProgress<Single> progress = null)
IObservable<AssetBundle>	LoadFromCacheOrDownload(String url, Int32 version, UInt32 crc, IProgress<Single> progress = null)
IObservable<AssetBundle>	LoadFromCacheOrDownload(String url, Hash128 hash128, IProgress<Single> progress = null)
IObservable<AssetBundle>	LoadFromCacheOrDownload(String url, Hash128 hash128, UInt32 crc, IProgress<Single> progress = null)
IObservable<String>	Post(String url, Byte[] postData, IProgress<Single> progress = null)
IObservable<String>	Post(String url, Byte[] postData, Dictionary<String, String> headers, IProgress<Single> progress = null)
IObservable<String>	Post(String url, WWWForm content, IProgress<Single> progress = null)
IObservable<String>	Post(String url, WWWForm content, Dictionary<String, String> headers, IProgress<Single> progress = null)
IObservable<Byte[]>	PostAndGetBytes(String url, Byte[] postData, IProgress<Single> progress = null)
IObservable<Byte[]>	PostAndGetBytes(String url, Byte[] postData, Dictionary<String, String> headers, IProgress<Single> progress = null)
IObservable<Byte[]>	PostAndGetBytes(String url, WWWForm content, IProgress<Single> progress = null)
IObservable<Byte[]>	PostAndGetBytes(String url, WWWForm content, Dictionary<String, String> headers, IProgress<Single> progress = null)
IObservable<WWW>	PostWWW(String url, Byte[] postData, IProgress<Single> progress = null)
IObservable<WWW>	PostWWW(String url, Byte[] postData, Dictionary<String, String> headers, IProgress<Single> progress = null)
IObservable<WWW>	PostWWW(String url, WWWForm content, IProgress<Single> progress = null)
IObservable<WWW>	PostWWW(String url, WWWForm content, Dictionary<String, String> headers, IProgress<Single> progress = null)

ObservableYieldInstruction<T>

public class UniRx.ObservableYieldInstruction<T>
    : IEnumerator<T>, IDisposable, IEnumerator, ICustomYieldInstructionErrorHandler

Properties

Type	Name	Summary
Exception	Error
Boolean	HasError
Boolean	HasResult
Boolean	IsCanceled
Boolean	IsDone	HasResult
T	Result

Methods

Type	Name	Summary
void	Dispose()

ObserveExtensions

public static class UniRx.ObserveExtensions

Static Methods

Type	Name	Summary
IObservable<TProperty>	ObserveEveryValueChanged(this TSource source, Func<TSource, TProperty> propertySelector, FrameCountType frameCountType = Update, Boolean fastDestroyCheck = False)	Publish target property when value is changed. If source is destroyed/destructed, publish OnCompleted.
IObservable<TProperty>	ObserveEveryValueChanged(this TSource source, Func<TSource, TProperty> propertySelector, FrameCountType frameCountType, IEqualityComparer<TProperty> comparer)	Publish target property when value is changed. If source is destroyed/destructed, publish OnCompleted.
IObservable<TProperty>	ObserveEveryValueChanged(this TSource source, Func<TSource, TProperty> propertySelector, FrameCountType frameCountType, IEqualityComparer<TProperty> comparer, Boolean fastDestroyCheck)	Publish target property when value is changed. If source is destroyed/destructed, publish OnCompleted.

Observer

public static class UniRx.Observer

Static Methods

Type	Name	Summary
IObserver<T>	Create(Action<T> onNext)
IObserver<T>	Create(Action<T> onNext, Action<Exception> onError)
IObserver<T>	Create(Action<T> onNext, Action onCompleted)
IObserver<T>	Create(Action<T> onNext, Action<Exception> onError, Action onCompleted)
IObserver<T>	CreateAutoDetachObserver(IObserver<T> observer, IDisposable disposable)
IObserver<T>	CreateSubscribeObserver(Action<T> onNext, Action<Exception> onError, Action onCompleted)
IObserver<T>	CreateSubscribeWithState2Observer(TState1 state1, TState2 state2, Action<T, TState1, TState2> onNext, Action<Exception, TState1, TState2> onError, Action<TState1, TState2> onCompleted)
IObserver<T>	CreateSubscribeWithState3Observer(TState1 state1, TState2 state2, TState3 state3, Action<T, TState1, TState2, TState3> onNext, Action<Exception, TState1, TState2, TState3> onError, Action<TState1, TState2, TState3> onCompleted)
IObserver<T>	CreateSubscribeWithStateObserver(TState state, Action<T, TState> onNext, Action<Exception, TState> onError, Action<TState> onCompleted)

ObserverExtensions

public static class UniRx.ObserverExtensions

Static Methods

Type	Name	Summary
IObserver<T>	Synchronize(this IObserver<T> observer)
IObserver<T>	Synchronize(this IObserver<T> observer, Object gate)

OptimizedObservableExtensions

public static class UniRx.OptimizedObservableExtensions

Static Methods

Type	Name	Summary
Boolean	IsRequiredSubscribeOnCurrentThread(this IObservable<T> source)
Boolean	IsRequiredSubscribeOnCurrentThread(this IObservable<T> source, IScheduler scheduler)

Pair<T>

public struct UniRx.Pair<T>
    : IEquatable<Pair<T>>

Properties

Type	Name	Summary
T	Current
T	Previous

Methods

Type	Name	Summary
Boolean	Equals(Object obj)
Boolean	Equals(Pair<T> other)
Int32	GetHashCode()
String	ToString()

QuaternionReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.QuaternionReactiveProperty
    : ReactiveProperty<Quaternion>, IReactiveProperty<Quaternion>, IReadOnlyReactiveProperty<Quaternion>, IObservable<Quaternion>, IDisposable, IOptimizedObservable<Quaternion>, IObserverLinkedList<Quaternion>

Properties

Type	Name	Summary
IEqualityComparer<Quaternion>	EqualityComparer

RangeReactivePropertyAttribute

Enables range input field for Int/FloatReactiveProperty.

public class UniRx.RangeReactivePropertyAttribute
    : PropertyAttribute, _Attribute

Properties

Type	Name	Summary
Single	Max
Single	Min

ReactiveCollection<T>

public class UniRx.ReactiveCollection<T>
    : Collection<T>, IList<T>, ICollection<T>, IEnumerable<T>, IEnumerable, IList, ICollection, IReadOnlyList<T>, IReadOnlyCollection<T>, IReactiveCollection<T>, IReadOnlyReactiveCollection<T>, IDisposable

Methods

Type	Name	Summary
void	ClearItems()
void	Dispose(Boolean disposing)
void	Dispose()
void	InsertItem(Int32 index, T item)
void	Move(Int32 oldIndex, Int32 newIndex)
void	MoveItem(Int32 oldIndex, Int32 newIndex)
IObservable<CollectionAddEvent<T>>	ObserveAdd()
IObservable<Int32>	ObserveCountChanged(Boolean notifyCurrentCount = False)
IObservable<CollectionMoveEvent<T>>	ObserveMove()
IObservable<CollectionRemoveEvent<T>>	ObserveRemove()
IObservable<CollectionReplaceEvent<T>>	ObserveReplace()
IObservable<Unit>	ObserveReset()
void	RemoveItem(Int32 index)
void	SetItem(Int32 index, T item)

ReactiveCollectionExtensions

public static class UniRx.ReactiveCollectionExtensions

Static Methods

Type	Name	Summary
ReactiveCollection<T>	ToReactiveCollection(this IEnumerable<T> source)

ReactiveCommand

Represents ReactiveCommand<Unit>

public class UniRx.ReactiveCommand
    : ReactiveCommand<Unit>, IReactiveCommand<Unit>, IObservable<Unit>, IDisposable

Methods

Type	Name	Summary
Boolean	Execute()	Push null to subscribers.
void	ForceExecute()	Force push parameter to subscribers.

ReactiveCommand<T>

public class UniRx.ReactiveCommand<T>
    : IReactiveCommand<T>, IObservable<T>, IDisposable

Properties

Type	Name	Summary
IReadOnlyReactiveProperty<Boolean>	CanExecute
Boolean	IsDisposed

Methods

Type	Name	Summary
void	Dispose()	Stop all subscription and lock CanExecute is false.
Boolean	Execute(T parameter)	Push parameter to subscribers when CanExecute.
void	ForceExecute(T parameter)	Force push parameter to subscribers.
IDisposable	Subscribe(IObserver<T> observer)	Subscribe execute.
UniTask<T>	WaitUntilExecuteAsync()

ReactiveCommandExtensions

public static class UniRx.ReactiveCommandExtensions

Static Methods

Type	Name	Summary
IDisposable	BindTo(this IReactiveCommand<Unit> command, Button button)	Bind ReactiveCommand to button's interactable and onClick.
IDisposable	BindToButtonOnClick(this IObservable<Boolean> canExecuteSource, Button button, Action<Unit> onClick, Boolean initialValue = True)	Bind canExecuteSource to button's interactable and onClick and register onClick action to command.
IDisposable	BindToOnClick(this IReactiveCommand<Unit> command, Button button, Action<Unit> onClick)	Bind ReactiveCommand to button's interactable and onClick and register onClick action to command.
Awaiter<T>	GetAwaiter(this IReactiveCommand<T> command)
ReactiveCommand	ToReactiveCommand(this IObservable<Boolean> canExecuteSource, Boolean initialValue = True)	Create non parameter commands. CanExecute is changed from canExecute sequence.
ReactiveCommand<T>	ToReactiveCommand(this IObservable<Boolean> canExecuteSource, Boolean initialValue = True)	Create non parameter commands. CanExecute is changed from canExecute sequence.

ReactiveDictionary<TKey, TValue>

public class UniRx.ReactiveDictionary<TKey, TValue>
    : IReactiveDictionary<TKey, TValue>, IReadOnlyReactiveDictionary<TKey, TValue>, IEnumerable<KeyValuePair<TKey, TValue>>, IEnumerable, IDictionary<TKey, TValue>, ICollection<KeyValuePair<TKey, TValue>>, IDictionary, ICollection, IDisposable, ISerializable, IDeserializationCallback

Properties

Type	Name	Summary
Int32	Count
TValue	Item
KeyCollection<TKey, TValue>	Keys
ValueCollection<TKey, TValue>	Values

Methods

Type	Name	Summary
void	Add(TKey key, TValue value)
void	Clear()
Boolean	ContainsKey(TKey key)
void	Dispose(Boolean disposing)
void	Dispose()
Enumerator<TKey, TValue>	GetEnumerator()
void	GetObjectData(SerializationInfo info, StreamingContext context)
IObservable<DictionaryAddEvent<TKey, TValue>>	ObserveAdd()
IObservable<Int32>	ObserveCountChanged(Boolean notifyCurrentCount = False)
IObservable<DictionaryRemoveEvent<TKey, TValue>>	ObserveRemove()
IObservable<DictionaryReplaceEvent<TKey, TValue>>	ObserveReplace()
IObservable<Unit>	ObserveReset()
void	OnDeserialization(Object sender)
Boolean	Remove(TKey key)
Boolean	TryGetValue(TKey key, TValue& value)

ReactiveDictionaryExtensions

public static class UniRx.ReactiveDictionaryExtensions

Static Methods

Type	Name	Summary
ReactiveDictionary<TKey, TValue>	ToReactiveDictionary(this Dictionary<TKey, TValue> dictionary)

ReactiveProperty<T>

Lightweight property broker.

public class UniRx.ReactiveProperty<T>
    : IReactiveProperty<T>, IReadOnlyReactiveProperty<T>, IObservable<T>, IDisposable, IOptimizedObservable<T>, IObserverLinkedList<T>

Properties

Type	Name	Summary
IEqualityComparer<T>	EqualityComparer
Boolean	HasValue
T	Value

Methods

Type	Name	Summary
void	Dispose()
void	Dispose(Boolean disposing)
Boolean	IsRequiredSubscribeOnCurrentThread()
void	SetValue(T value)
void	SetValueAndForceNotify(T value)
IDisposable	Subscribe(IObserver<T> observer)
String	ToString()
UniTask<T>	WaitUntilValueChangedAsync()

ReactivePropertyExtensions

Extension methods of ReactiveProperty<T>

public static class UniRx.ReactivePropertyExtensions

Static Methods

Type	Name	Summary
IObservable<Boolean>	CombineLatestValuesAreAllFalse(this IEnumerable<IObservable<Boolean>> sources)	Lastest values of each sequence are all false.
IObservable<Boolean>	CombineLatestValuesAreAllTrue(this IEnumerable<IObservable<Boolean>> sources)	Lastest values of each sequence are all true.
Awaiter<T>	GetAwaiter(this IReadOnlyReactiveProperty<T> source)
IObservable<T>	SkipLatestValueOnSubscribe(this IReadOnlyReactiveProperty<T> source)
IReadOnlyReactiveProperty<T>	ToReactiveProperty(this IObservable<T> source)
IReadOnlyReactiveProperty<T>	ToReactiveProperty(this IObservable<T> source, T initialValue)
ReadOnlyReactiveProperty<T>	ToReadOnlyReactiveProperty(this IObservable<T> source)
ReadOnlyReactiveProperty<T>	ToReadOnlyReactiveProperty(this IObservable<T> source, T initialValue)
ReadOnlyReactiveProperty<T>	ToSequentialReadOnlyReactiveProperty(this IObservable<T> source)	Create ReadOnlyReactiveProperty with distinctUntilChanged: false.
ReadOnlyReactiveProperty<T>	ToSequentialReadOnlyReactiveProperty(this IObservable<T> source, T initialValue)	Create ReadOnlyReactiveProperty with distinctUntilChanged: false.

ReadOnlyReactiveProperty<T>

Lightweight property broker.

public class UniRx.ReadOnlyReactiveProperty<T>
    : IReadOnlyReactiveProperty<T>, IObservable<T>, IDisposable, IOptimizedObservable<T>, IObserverLinkedList<T>, IObserver<T>

Properties

Type	Name	Summary
IEqualityComparer<T>	EqualityComparer
Boolean	HasValue
T	Value

Methods

Type	Name	Summary
void	Dispose()
void	Dispose(Boolean disposing)
Boolean	IsRequiredSubscribeOnCurrentThread()
IDisposable	Subscribe(IObserver<T> observer)
String	ToString()
UniTask<T>	WaitUntilValueChangedAsync()

RectReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.RectReactiveProperty
    : ReactiveProperty<Rect>, IReactiveProperty<Rect>, IReadOnlyReactiveProperty<Rect>, IObservable<Rect>, IDisposable, IOptimizedObservable<Rect>, IObserverLinkedList<Rect>

Properties

Type	Name	Summary
IEqualityComparer<Rect>	EqualityComparer

RefCountDisposable

Represents a disposable resource that only disposes its underlying disposable resource when all dependent disposable objects have been disposed.

public class UniRx.RefCountDisposable
    : ICancelable, IDisposable

Properties

Type	Name	Summary
Boolean	IsDisposed	Gets a value that indicates whether the object is disposed.

Methods

Type	Name	Summary
void	Dispose()	Disposes the underlying disposable only when all dependent disposables have been disposed.
IDisposable	GetDisposable()	Returns a dependent disposable that when disposed decreases the refcount on the underlying disposable.

ReplaySubject<T>

public class UniRx.ReplaySubject<T>
    : ISubject<T>, ISubject<T, T>, IObserver<T>, IObservable<T>, IOptimizedObservable<T>, IDisposable

Methods

Type	Name	Summary
void	Dispose()
Boolean	IsRequiredSubscribeOnCurrentThread()
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)
IDisposable	Subscribe(IObserver<T> observer)

ScenePlaybackDetector

public class UniRx.ScenePlaybackDetector

Static Properties

Type	Name	Summary
Boolean	IsPlaying

Static Methods

Type	Name	Summary
void	OnDidReloadScripts()

ScheduledDisposable

public class UniRx.ScheduledDisposable
    : ICancelable, IDisposable

Properties

Type	Name	Summary
IDisposable	Disposable
Boolean	IsDisposed
IScheduler	Scheduler

Methods

Type	Name	Summary
void	Dispose()

ScheduledNotifier<T>

Notify value on setuped scheduler.

public class UniRx.ScheduledNotifier<T>
    : IObservable<T>, IProgress<T>

Methods

Type	Name	Summary
void	Report(T value)	Push value to subscribers on setuped scheduler.
IDisposable	Report(T value, TimeSpan dueTime)	Push value to subscribers on setuped scheduler.
IDisposable	Report(T value, DateTimeOffset dueTime)	Push value to subscribers on setuped scheduler.
IDisposable	Subscribe(IObserver<T> observer)	Subscribe observer.

Scheduler

public static class UniRx.Scheduler

Static Fields

Type	Name	Summary
IScheduler	CurrentThread
IScheduler	Immediate
IScheduler	ThreadPool

Static Properties

Type	Name	Summary
Boolean	IsCurrentThreadSchedulerScheduleRequired
IScheduler	MainThread	Unity native MainThread Queue Scheduler. Run on mainthread and delayed on coroutine update loop, elapsed time is calculated based on Time.time.
IScheduler	MainThreadEndOfFrame	Run on end of frame mainthread, delay elapsed time is calculated based on Time.deltaTime.
IScheduler	MainThreadFixedUpdate	Run on fixed update mainthread, delay elapsed time is calculated based on Time.fixedTime.
IScheduler	MainThreadIgnoreTimeScale	Another MainThread scheduler, delay elapsed time is calculated based on Time.unscaledDeltaTime.
DateTimeOffset	Now

Static Methods

Type	Name	Summary
TimeSpan	Normalize(TimeSpan timeSpan)
IDisposable	Schedule(this IScheduler scheduler, DateTimeOffset dueTime, Action action)
IDisposable	Schedule(this IScheduler scheduler, Action<Action> action)
IDisposable	Schedule(this IScheduler scheduler, TimeSpan dueTime, Action<Action<TimeSpan>> action)
IDisposable	Schedule(this IScheduler scheduler, DateTimeOffset dueTime, Action<Action<DateTimeOffset>> action)
void	SetDefaultForUnity()

SerialDisposable

public class UniRx.SerialDisposable
    : IDisposable, ICancelable

Properties

Type	Name	Summary
IDisposable	Disposable
Boolean	IsDisposed

Methods

Type	Name	Summary
void	Dispose()

SingleAssignmentDisposable

public class UniRx.SingleAssignmentDisposable
    : IDisposable, ICancelable

Properties

Type	Name	Summary
IDisposable	Disposable
Boolean	IsDisposed

Methods

Type	Name	Summary
void	Dispose()

StableCompositeDisposable

Represents a group of disposable resources that are disposed together.

public abstract class UniRx.StableCompositeDisposable
    : ICancelable, IDisposable

Properties

Type	Name	Summary
Boolean	IsDisposed	Gets a value that indicates whether the object is disposed.

Methods

Type	Name	Summary
void	Dispose()	Disposes all disposables in the group.

Static Methods

Type	Name	Summary
ICancelable	Create(IDisposable disposable1, IDisposable disposable2)	Creates a new group containing two disposable resources that are disposed together.
ICancelable	Create(IDisposable disposable1, IDisposable disposable2, IDisposable disposable3)	Creates a new group containing two disposable resources that are disposed together.
ICancelable	Create(IDisposable disposable1, IDisposable disposable2, IDisposable disposable3, IDisposable disposable4)	Creates a new group containing two disposable resources that are disposed together.
ICancelable	Create(IDisposable[] disposables)	Creates a new group containing two disposable resources that are disposed together.
ICancelable	Create(IEnumerable<IDisposable> disposables)	Creates a new group containing two disposable resources that are disposed together.
ICancelable	CreateUnsafe(IDisposable[] disposables)	Creates a new group of disposable resources that are disposed together. Array is not copied, it's unsafe but optimized.

StringReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.StringReactiveProperty
    : ReactiveProperty<String>, IReactiveProperty<String>, IReadOnlyReactiveProperty<String>, IObservable<String>, IDisposable, IOptimizedObservable<String>, IObserverLinkedList<String>

Subject<T>

public class UniRx.Subject<T>
    : ISubject<T>, ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable, IOptimizedObservable<T>

Properties

Type	Name	Summary
Boolean	HasObservers

Methods

Type	Name	Summary
void	Dispose()
Boolean	IsRequiredSubscribeOnCurrentThread()
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)
IDisposable	Subscribe(IObserver<T> observer)

SubjectExtensions

public static class UniRx.SubjectExtensions

Static Methods

Type	Name	Summary
ISubject<T>	Synchronize(this ISubject<T> subject)
ISubject<T>	Synchronize(this ISubject<T> subject, Object gate)

TaskObservableExtensions

Provides a set of static methods for converting tasks to observable sequences.

public static class UniRx.TaskObservableExtensions

Static Methods

Type	Name	Summary
IObservable<Unit>	ToObservable(this Task task)	Returns an observable sequence that signals when the task completes.
IObservable<Unit>	ToObservable(this Task task, IScheduler scheduler)	Returns an observable sequence that signals when the task completes.
IObservable<TResult>	ToObservable(this Task<TResult> task)	Returns an observable sequence that signals when the task completes.
IObservable<TResult>	ToObservable(this Task<TResult> task, IScheduler scheduler)	Returns an observable sequence that signals when the task completes.
Task<TResult>	ToTask(this IObservable<TResult> observable)	Returns a task that will receive the last value or the exception produced by the observable sequence.
Task<TResult>	ToTask(this IObservable<TResult> observable, Object state)	Returns a task that will receive the last value or the exception produced by the observable sequence.
Task<TResult>	ToTask(this IObservable<TResult> observable, CancellationToken cancellationToken)	Returns a task that will receive the last value or the exception produced by the observable sequence.
Task<TResult>	ToTask(this IObservable<TResult> observable, CancellationToken cancellationToken, Object state)	Returns a task that will receive the last value or the exception produced by the observable sequence.

TimeInterval<T>

Represents a value associated with time interval information. The time interval can represent the time it took to produce the value, the interval relative to a previous value, the value's delivery time relative to a base, etc.

public struct UniRx.TimeInterval<T>
    : IEquatable<TimeInterval<T>>

Properties

Type	Name	Summary
TimeSpan	Interval	Gets the interval.
T	Value	Gets the value.

Methods

Type	Name	Summary
Boolean	Equals(TimeInterval<T> other)	Determines whether the current TimeInterval<T> value has the same Value and Interval as a specified TimeInterval<T> value.
Boolean	Equals(Object obj)	Determines whether the current TimeInterval<T> value has the same Value and Interval as a specified TimeInterval<T> value.
Int32	GetHashCode()	Returns the hash code for the current TimeInterval<T> value.
String	ToString()	Returns a string representation of the current TimeInterval<T> value.

Timestamped

A helper class with a factory method for creating Timestamped<T> instances.

public static class UniRx.Timestamped

Static Methods

Type	Name	Summary
Timestamped<T>	Create(T value, DateTimeOffset timestamp)	Creates an instance of a Timestamped<T>. This is syntactic sugar that uses type inference to avoid specifying a type in a constructor call, which is very useful when using anonymous types.

Timestamped<T>

Represents value with a timestamp on it. The timestamp typically represents the time the value was received, using an IScheduler's clock to obtain the current time.

public struct UniRx.Timestamped<T>
    : IEquatable<Timestamped<T>>

Properties

Type	Name	Summary
DateTimeOffset	Timestamp	Gets the timestamp.
T	Value	Gets the value.

Methods

Type	Name	Summary
Boolean	Equals(Timestamped<T> other)	Determines whether the current Timestamped<T> value has the same Value and Timestamp as a specified Timestamped<T> value.
Boolean	Equals(Object obj)	Determines whether the current Timestamped<T> value has the same Value and Timestamp as a specified Timestamped<T> value.
Int32	GetHashCode()	Returns the hash code for the current Timestamped<T> value.
String	ToString()	Returns a string representation of the current Timestamped<T> value.

Unit

public struct UniRx.Unit
    : IEquatable<Unit>

Methods

Type	Name	Summary
Boolean	Equals(Unit other)
Boolean	Equals(Object obj)
Int32	GetHashCode()
String	ToString()

Static Properties

Type	Name	Summary
Unit	Default

UniTaskObservableExtensions

public static class UniRx.UniTaskObservableExtensions

Static Methods

Type	Name	Summary
IObservable<T>	ToObservable(this UniTask<T> task)
IObservable<Unit>	ToObservable(this UniTask task)
UniTask<T>	ToUniTask(this IObservable<T> source, CancellationToken cancellationToken = null, Boolean useFirstValue = False)

UnityEqualityComparer

public static class UniRx.UnityEqualityComparer

Static Fields

Type	Name	Summary
IEqualityComparer<Bounds>	Bounds
IEqualityComparer<Color>	Color
IEqualityComparer<Quaternion>	Quaternion
IEqualityComparer<Rect>	Rect
IEqualityComparer<Vector2>	Vector2
IEqualityComparer<Vector3>	Vector3
IEqualityComparer<Vector4>	Vector4

Static Methods

Type	Name	Summary
IEqualityComparer<T>	GetDefault()

UnityEventExtensions

public static class UniRx.UnityEventExtensions

Static Methods

Type	Name	Summary
IObservable<Unit>	AsObservable(this UnityEvent unityEvent)
IObservable<T>	AsObservable(this UnityEvent<T> unityEvent)
IObservable<Tuple<T0, T1>>	AsObservable(this UnityEvent<T0, T1> unityEvent)
IObservable<Tuple<T0, T1, T2>>	AsObservable(this UnityEvent<T0, T1, T2> unityEvent)
IObservable<Tuple<T0, T1, T2, T3>>	AsObservable(this UnityEvent<T0, T1, T2, T3> unityEvent)

UnityGraphicExtensions

public static class UniRx.UnityGraphicExtensions

Static Methods

Type	Name	Summary
IObservable<Unit>	DirtyLayoutCallbackAsObservable(this Graphic graphic)
IObservable<Unit>	DirtyMaterialCallbackAsObservable(this Graphic graphic)
IObservable<Unit>	DirtyVerticesCallbackAsObservable(this Graphic graphic)

UnityUIComponentExtensions

public static class UniRx.UnityUIComponentExtensions

Static Methods

Type	Name	Summary
IObservable<Unit>	OnClickAsObservable(this Button button)	Observe onClick event.
IObservable<String>	OnEndEditAsObservable(this InputField inputField)	Observe onEndEdit(Submit) event.
IObservable<Boolean>	OnValueChangedAsObservable(this Toggle toggle)	Observe onValueChanged with current isOn value on subscribe.
IObservable<Single>	OnValueChangedAsObservable(this Scrollbar scrollbar)	Observe onValueChanged with current isOn value on subscribe.
IObservable<Vector2>	OnValueChangedAsObservable(this ScrollRect scrollRect)	Observe onValueChanged with current isOn value on subscribe.
IObservable<Single>	OnValueChangedAsObservable(this Slider slider)	Observe onValueChanged with current isOn value on subscribe.
IObservable<String>	OnValueChangedAsObservable(this InputField inputField)	Observe onValueChanged with current isOn value on subscribe.
IDisposable	SubscribeToInteractable(this IObservable<Boolean> source, Selectable selectable)
IDisposable	SubscribeToText(this IObservable<String> source, Text text)
IDisposable	SubscribeToText(this IObservable<T> source, Text text)
IDisposable	SubscribeToText(this IObservable<T> source, Text text, Func<T, String> selector)

Vector2ReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.Vector2ReactiveProperty
    : ReactiveProperty<Vector2>, IReactiveProperty<Vector2>, IReadOnlyReactiveProperty<Vector2>, IObservable<Vector2>, IDisposable, IOptimizedObservable<Vector2>, IObserverLinkedList<Vector2>

Properties

Type	Name	Summary
IEqualityComparer<Vector2>	EqualityComparer

Vector3ReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.Vector3ReactiveProperty
    : ReactiveProperty<Vector3>, IReactiveProperty<Vector3>, IReadOnlyReactiveProperty<Vector3>, IObservable<Vector3>, IDisposable, IOptimizedObservable<Vector3>, IObserverLinkedList<Vector3>

Properties

Type	Name	Summary
IEqualityComparer<Vector3>	EqualityComparer

Vector4ReactiveProperty

Inspectable ReactiveProperty.

public class UniRx.Vector4ReactiveProperty
    : ReactiveProperty<Vector4>, IReactiveProperty<Vector4>, IReadOnlyReactiveProperty<Vector4>, IObservable<Vector4>, IDisposable, IOptimizedObservable<Vector4>, IObserverLinkedList<Vector4>

Properties

Type	Name	Summary
IEqualityComparer<Vector4>	EqualityComparer

WebRequestExtensions

public static class UniRx.WebRequestExtensions

Static Methods

Type	Name	Summary
IObservable<Stream>	GetRequestStreamAsObservable(this WebRequest request)
IObservable<WebResponse>	GetResponseAsObservable(this WebRequest request)
IObservable<HttpWebResponse>	GetResponseAsObservable(this HttpWebRequest request)

WWWErrorException

public class UniRx.WWWErrorException
    : Exception, ISerializable, _Exception

Properties

Type	Name	Summary
Boolean	HasResponse
String	RawErrorMessage
Dictionary<String, String>	ResponseHeaders
HttpStatusCode	StatusCode
String	Text
WWW	WWW

Methods

Type	Name	Summary
String	ToString()