rxjava 1.3.8 · rx.internal.operators.NotificationLite

Modifier and Type	Class and Description
pack-priv static class	NotificationLite.OnErrorSentinel

Modifier and Type	Field and Description
private static final Object	ON_COMPLETED_SENTINEL
private static final Object	ON_NEXT_NULL_SENTINEL

Access	Constructor and Description
private	NotificationLite()

Method Summary

Modifier and Type	Method and Description
public static < the value type to accept T> boolean	Returns: `true` if `n` represents a termination event; `false` otherwise accept(Observer<? super T> the `Observer` to call `onNext`, `onCompleted`, or `onError`. o, Object the lite notification n) Unwraps the lite notification and calls the appropriate method on the `Observer`.
public static Object	Returns: a completion token completed() Creates a lite `onCompleted` notification without doing any allocation.
public static Object	Returns: an object encapsulating the exception error(Throwable the `Throwable` in the `onError` notification e) Create a lite `onError` notification.
public static Throwable	Returns: the `Throwable` wrapped inside `n` getError(Object the lite notification (of type `Kind.OnError`) n) Returns the `Throwable` corresponding to this `OnError` lite notification.
public static < the value type to convert T> T	Returns: the unwrapped value, which can be null getValue(Object the lite notification (of type `Kind.OnNext`) n) Returns the item corresponding to this `OnNext` lite notification.
public static boolean	Returns: `true` if `n` represents an `onCompleted` event; `false` otherwise isCompleted(Object the lite notification n) Indicates whether or not the lite notification represents an `onCompleted` event.
public static boolean	Returns: `true` if `n` represents an `onError` event; `false` otherwise isError(Object the lite notification n) Indicates whether or not the lite notification represents an `onError` event.
public static boolean	Returns: `true` if `n` represents an `onNext` event, `false` otherwise isNext(Object the lite notification n) Indicates whether or not the lite notification represents an `onNext` event.
public static boolean	Returns: `true` if `n` represents a wrapped `null` `onNext` event, `false` otherwise isNull(Object the lite notification n) Indicates whether or not the lite notification represents a wrapped `null` `onNext` event.
public static < the value type to convert T> Object	Returns: the item, or a null token representing the item if the item is `null` next(T the item emitted to `onNext` t) Creates a lite `onNext` notification for the value passed in without doing any allocation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

ON_COMPLETED_SENTINEL	back to summary
private static final Object ON_COMPLETED_SENTINEL

ON_NEXT_NULL_SENTINEL	back to summary
private static final Object ON_NEXT_NULL_SENTINEL

NotificationLite	back to summary
private NotificationLite()

Method Detail

accept back to summary

accept	back to summary
public static <T> boolean accept(Observer<? super T> o, Object n) Unwraps the lite notification and calls the appropriate method on the `Observer`. Parameters <T> the value type to accept o:Observer<? super T> the `Observer` to call `onNext`, `onCompleted`, or `onError`. n:Object the lite notification Returns:boolean `true` if `n` represents a termination event; `false` otherwise Annotations @SuppressWarnings:unchecked Exceptions IllegalArgumentException: if the notification is null. NullPointerException: if the `Observer` is null.

public static <T> boolean accept(Observer<? super T> o, Object n)

Unwraps the lite notification and calls the appropriate method on the Observer.

Parameters

<T>: the value type to accept
o:Observer<? super T>: the Observer to call onNext, onCompleted, or onError.
n:Object: the lite notification

Returns:boolean

true if n represents a termination event; false otherwise

Annotations

@SuppressWarnings:unchecked

Exceptions

IllegalArgumentException:: if the notification is null.
NullPointerException:: if the Observer is null.

completed back to summary

completed	back to summary
public static Object completed() Creates a lite `onCompleted` notification without doing any allocation. Can be unwrapped and sent with the `accept` method. Returns:Object a completion token

public static Object completed()

Creates a lite onCompleted notification without doing any allocation. Can be unwrapped and sent with the accept method.

Returns:Object: a completion token

error back to summary

error	back to summary
public static Object error(Throwable e) Create a lite `onError` notification. This call creates an object to wrap the `Throwable`, but since there should only be one of these, the performance impact should be small. Can be unwrapped and sent with the `accept` method. Parameters e:Throwable the `Throwable` in the `onError` notification Returns:Object an object encapsulating the exception

public static Object error(Throwable e)

Create a lite onError notification. This call creates an object to wrap the Throwable, but since there should only be one of these, the performance impact should be small. Can be unwrapped and sent with the accept method.

Parameters

e:Throwable: the Throwable in the onError notification

Returns:Object

an object encapsulating the exception

getError back to summary

getError	back to summary
public static Throwable getError(Object n) Returns the `Throwable` corresponding to this `OnError` lite notification. Bad things happen if you pass this an `OnComplete` or `OnNext` notification type. For performance reasons, this method does not check for this, so you are expected to prevent such a mishap. Parameters n:Object the lite notification (of type `Kind.OnError`) Returns:Throwable the `Throwable` wrapped inside `n`

public static Throwable getError(Object n)

Returns the Throwable corresponding to this OnError lite notification. Bad things happen if you pass this an OnComplete or OnNext notification type. For performance reasons, this method does not check for this, so you are expected to prevent such a mishap.

Parameters

n:Object: the lite notification (of type Kind.OnError)

Returns:Throwable

the Throwable wrapped inside n

getValue back to summary

getValue	back to summary
public static <T> T getValue(Object n) Returns the item corresponding to this `OnNext` lite notification. Bad things happen if you pass this an `OnComplete` or `OnError` notification type. For performance reasons, this method does not check for this, so you are expected to prevent such a mishap. Parameters <T> the value type to convert n:Object the lite notification (of type `Kind.OnNext`) Returns:T the unwrapped value, which can be null Annotations @SuppressWarnings:unchecked

public static <T> T getValue(Object n)

Returns the item corresponding to this OnNext lite notification. Bad things happen if you pass this an OnComplete or OnError notification type. For performance reasons, this method does not check for this, so you are expected to prevent such a mishap.

Parameters

<T>: the value type to convert
n:Object: the lite notification (of type Kind.OnNext)

Returns:T

the unwrapped value, which can be null

Annotations

@SuppressWarnings:unchecked

isCompleted back to summary

isCompleted	back to summary
public static boolean isCompleted(Object n) Indicates whether or not the lite notification represents an `onCompleted` event. Parameters n:Object the lite notification Returns:boolean `true` if `n` represents an `onCompleted` event; `false` otherwise

public static boolean isCompleted(Object n)

Indicates whether or not the lite notification represents an onCompleted event.

Parameters

n:Object: the lite notification

Returns:boolean

true if n represents an onCompleted event; false otherwise

isError back to summary

isError	back to summary
public static boolean isError(Object n) Indicates whether or not the lite notification represents an `onError` event. Parameters n:Object the lite notification Returns:boolean `true` if `n` represents an `onError` event; `false` otherwise

public static boolean isError(Object n)

Indicates whether or not the lite notification represents an onError event.

Parameters

n:Object: the lite notification

Returns:boolean

true if n represents an onError event; false otherwise

isNext back to summary

isNext	back to summary
public static boolean isNext(Object n) Indicates whether or not the lite notification represents an `onNext` event. Parameters n:Object the lite notification Returns:boolean `true` if `n` represents an `onNext` event, `false` otherwise

public static boolean isNext(Object n)

Indicates whether or not the lite notification represents an onNext event.

Parameters

n:Object: the lite notification

Returns:boolean

true if n represents an onNext event, false otherwise

isNull back to summary

isNull	back to summary
public static boolean isNull(Object n) Indicates whether or not the lite notification represents a wrapped `null` `onNext` event. Parameters n:Object the lite notification Returns:boolean `true` if `n` represents a wrapped `null` `onNext` event, `false` otherwise

public static boolean isNull(Object n)

Indicates whether or not the lite notification represents a wrapped null onNext event.

Parameters

n:Object: the lite notification

Returns:boolean

true if n represents a wrapped null onNext event, false otherwise

next back to summary

next	back to summary
public static <T> Object next(T t) Creates a lite `onNext` notification for the value passed in without doing any allocation. Can be unwrapped and sent with the `accept` method. Parameters <T> the value type to convert t:T the item emitted to `onNext` Returns:Object the item, or a null token representing the item if the item is `null`

public static <T> Object next(T t)

Creates a lite onNext notification for the value passed in without doing any allocation. Can be unwrapped and sent with the accept method.

Parameters

<T>: the value type to convert
t:T: the item emitted to onNext

Returns:Object

the item, or a null token representing the item if the item is null

Modifier and Type	Field and Description
pack-priv final Throwable	e
private static final long	serialVersionUID

public final Class NotificationLite

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class NotificationLite.OnErrorSentinel

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail