UniRx.InternalUtil - neuecc/UniRx GitHub Wiki

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
⚠️ **GitHub.com Fallback** ⚠️