Skip to content
This repository has been archived by the owner on Feb 16, 2024. It is now read-only.

UniRx.InternalUtil

neuecc edited this page Jul 26, 2016 · 3 revisions

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