UniRx.InternalUtil

DisposedObserver<T>

public class UniRx.InternalUtil.DisposedObserver<T>
    : IObserver<T>

Methods

Type	Name	Summary
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)

Static Fields

Type	Name	Summary
DisposedObserver<T>	Instance

EmptyObserver<T>

public class UniRx.InternalUtil.EmptyObserver<T>
    : IObserver<T>

Methods

Type	Name	Summary
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)

Static Fields

Type	Name	Summary
EmptyObserver<T>	Instance

ImmutableList<T>

public class UniRx.InternalUtil.ImmutableList<T>

Properties

Type	Name	Summary
T[]	Data

Methods

Type	Name	Summary
ImmutableList<T>	Add(T value)
Int32	IndexOf(T value)
ImmutableList<T>	Remove(T value)

Static Fields

Type	Name	Summary
ImmutableList<T>	Empty

ListObserver<T>

public class UniRx.InternalUtil.ListObserver<T>
    : IObserver<T>

Methods

Type	Name	Summary
IObserver<T>	Add(IObserver<T> observer)
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)
IObserver<T>	Remove(IObserver<T> observer)

MicroCoroutine

Simple supports(only yield return null) lightweight, threadsafe coroutine dispatcher.

public class UniRx.InternalUtil.MicroCoroutine

Methods

Type	Name	Summary
void	AddCoroutine(IEnumerator enumerator)
void	Run()

ThreadSafeQueueWorker

public class UniRx.InternalUtil.ThreadSafeQueueWorker

Methods

Type	Name	Summary
void	Enqueue(Action<Object> action, Object state)
void	ExecuteAll(Action<Exception> unhandledExceptionCallback)

ThrowObserver<T>

public class UniRx.InternalUtil.ThrowObserver<T>
    : IObserver<T>

Methods

Type	Name	Summary
void	OnCompleted()
void	OnError(Exception error)
void	OnNext(T value)

Static Fields

Type	Name	Summary
ThrowObserver<T>	Instance