Top Description Inners Constructors Methods
io.reactivex.internal.operators.single

public final Class SingleInternalHelper

extends Object
Class Inheritance
Imports
java.util.*, java.util.concurrent.Callable, org.reactivestreams.Publisher, io.reactivex.*, .Observable, io.reactivex.functions.Function

Helper utility class to support Single with inner classes.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static enum
pack-priv static enum
pack-priv static class
pack-priv static class
pack-priv static enum

Constructor Summary

AccessConstructor and Description
private
SingleInternalHelper()

Utility class.

Method Summary

Modifier and TypeMethod and Description
public static <T> Callable<NoSuchElementException>
public static <T> Iterable<? extends Flowable<T>>
iterableToFlowable(final Iterable<? extends SingleSource<? extends T>> sources)

public static <T> Function<SingleSource<? extends T>, Publisher<? extends T>>
public static <T> Function<SingleSource<? extends T>, Observable<? extends T>>
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

SingleInternalHelperback to summary
private SingleInternalHelper()

Utility class.

Method Detail

emptyThrowerback to summary
public static <T> Callable<NoSuchElementException> emptyThrower()
iterableToFlowableback to summary
public static <T> Iterable<? extends Flowable<T>> iterableToFlowable(final Iterable<? extends SingleSource<? extends T>> sources)
toFlowableback to summary
public static <T> Function<SingleSource<? extends T>, Publisher<? extends T>> toFlowable()
Annotations
@SuppressWarnings:rawtypes, unchecked
toObservableback to summary
public static <T> Function<SingleSource<? extends T>, Observable<? extends T>> toObservable()
Annotations
@SuppressWarnings:rawtypes, unchecked
io.reactivex.internal.operators.single back to summary

pack-priv final Enum SingleInternalHelper.NoSuchElementCallable

extends Enum<SingleInternalHelper.NoSuchElementCallable>
implements Callable<NoSuchElementException>
Class Inheritance
All Implemented Interfaces
java.util.concurrent.Callable

Field Summary

Modifier and TypeField and Description
public static final SingleInternalHelper.NoSuchElementCallable

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public NoSuchElementException
call()

Implements java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.
public static SingleInternalHelper.NoSuchElementCallable
public static SingleInternalHelper.NoSuchElementCallable[]
Inherited from java.lang.Enum:
clonecompareTodescribeConstableequalsfinalizegetDeclaringClasshashCodenameordinaltoStringvalueOf

Field Detail

INSTANCEback to summary
public static final SingleInternalHelper.NoSuchElementCallable INSTANCE

Constructor Detail

NoSuchElementCallableback to summary
private NoSuchElementCallable()

Method Detail

callback to summary
public NoSuchElementException call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:NoSuchElementException

computed result

Annotations
@Override
Exceptions
Exception:
if unable to compute a result
valueOfback to summary
public static SingleInternalHelper.NoSuchElementCallable valueOf(String name)
valuesback to summary
public static SingleInternalHelper.NoSuchElementCallable[] values()
io.reactivex.internal.operators.single back to summary

pack-priv final Enum SingleInternalHelper.ToFlowable

extends Enum<SingleInternalHelper.ToFlowable>
implements Function<SingleSource<T>, Publisher<T>>
Class Inheritance
All Implemented Interfaces
io.reactivex.functions.Function
Annotations
@SuppressWarnings:rawtypes

Field Summary

Modifier and TypeField and Description
public static final SingleInternalHelper.ToFlowable

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public Publisher<T>
apply(SingleSource<T>
the input value
v
)

Implements io.reactivex.functions.Function.apply.

Apply some calculation to the input value and return some other value.
public static SingleInternalHelper.ToFlowable
public static SingleInternalHelper.ToFlowable[]
Inherited from java.lang.Enum:
clonecompareTodescribeConstableequalsfinalizegetDeclaringClasshashCodenameordinaltoStringvalueOf

Field Detail

INSTANCEback to summary
public static final SingleInternalHelper.ToFlowable INSTANCE

Constructor Detail

ToFlowableback to summary
private ToFlowable()

Method Detail

applyback to summary
public Publisher<T> apply(SingleSource<T> v)

Implements io.reactivex.functions.Function.apply.

Doc from io.reactivex.functions.Function.apply.

Apply some calculation to the input value and return some other value.

Parameters
v:SingleSource<T>

the input value

Returns:Publisher<T>

the output value

Annotations
@SuppressWarnings:unchecked
@Override
valueOfback to summary
public static SingleInternalHelper.ToFlowable valueOf(String name)
valuesback to summary
public static SingleInternalHelper.ToFlowable[] values()
io.reactivex.internal.operators.single back to summary

pack-priv final Class SingleInternalHelper.ToFlowableIterable<T>

extends Object
implements Iterable<Flowable<T>>
Class Inheritance
  • java.lang.Object
  • io.reactivex.internal.operators.single.SingleInternalHelper.ToFlowableIterable
All Implemented Interfaces
java.lang.Iterable

Field Summary

Modifier and TypeField and Description
private final Iterable<? extends SingleSource<? extends T>>

Constructor Summary

AccessConstructor and Description
pack-priv
ToFlowableIterable(Iterable<? extends SingleSource<? extends T>> sources)

Method Summary

Modifier and TypeMethod and Description
public Iterator<Flowable<T>>
iterator()

Implements java.lang.Iterable.iterator.

Returns an iterator over elements of type T.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sourcesback to summary
private final Iterable<? extends SingleSource<? extends T>> sources

Constructor Detail

ToFlowableIterableback to summary
pack-priv ToFlowableIterable(Iterable<? extends SingleSource<? extends T>> sources)

Method Detail

iteratorback to summary
public Iterator<Flowable<T>> iterator()

Implements java.lang.Iterable.iterator.

Doc from java.lang.Iterable.iterator.

Returns an iterator over elements of type T.

Returns:Iterator<Flowable<T>>

an Iterator.

Annotations
@Override
io.reactivex.internal.operators.single back to summary

pack-priv final Class SingleInternalHelper.ToFlowableIterator<T>

extends Object
implements Iterator<Flowable<T>>
Class Inheritance
  • java.lang.Object
  • io.reactivex.internal.operators.single.SingleInternalHelper.ToFlowableIterator
All Implemented Interfaces
java.util.Iterator

Field Summary

Modifier and TypeField and Description
private final Iterator<? extends SingleSource<? extends T>>

Constructor Summary

AccessConstructor and Description
pack-priv
ToFlowableIterator(Iterator<? extends SingleSource<? extends T>> sit)

Method Summary

Modifier and TypeMethod and Description
public boolean
hasNext()

Implements java.util.Iterator.hasNext.

Returns true if the iteration has more elements.
public Flowable<T>
next()

Implements java.util.Iterator.next.

Returns the next element in the iteration.
public void
remove()

Overrides default java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation).
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sitback to summary
private final Iterator<? extends SingleSource<? extends T>> sit

Constructor Detail

ToFlowableIteratorback to summary
pack-priv ToFlowableIterator(Iterator<? extends SingleSource<? extends T>> sit)

Method Detail

hasNextback to summary
public boolean hasNext()

Implements java.util.Iterator.hasNext.

Doc from java.util.Iterator.hasNext.

Returns true if the iteration has more elements. (In other words, returns true if next would return an element rather than throwing an exception.)

Returns:boolean

true if the iteration has more elements

Annotations
@Override
nextback to summary
public Flowable<T> next()

Implements java.util.Iterator.next.

Doc from java.util.Iterator.next.

Returns the next element in the iteration.

Returns:Flowable<T>

the next element in the iteration

Annotations
@Override
removeback to summary
public void remove()

Overrides default java.util.Iterator.remove.

Doc from java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation). This method can be called only once per call to next.

The behavior of an iterator is unspecified if the underlying collection is modified while the iteration is in progress in any way other than by calling this method, unless an overriding class has specified a concurrent modification policy.

The behavior of an iterator is unspecified if this method is called after a call to the forEachRemaining method.

Annotations
@Override
io.reactivex.internal.operators.single back to summary

pack-priv final Enum SingleInternalHelper.ToObservable

extends Enum<SingleInternalHelper.ToObservable>
implements Function<SingleSource<T>, Observable<T>>
Class Inheritance
All Implemented Interfaces
io.reactivex.functions.Function
Annotations
@SuppressWarnings:rawtypes

Field Summary

Modifier and TypeField and Description
public static final SingleInternalHelper.ToObservable

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public Observable<T>
apply(SingleSource<T>
the input value
v
)

Implements io.reactivex.functions.Function.apply.

Apply some calculation to the input value and return some other value.
public static SingleInternalHelper.ToObservable
public static SingleInternalHelper.ToObservable[]
Inherited from java.lang.Enum:
clonecompareTodescribeConstableequalsfinalizegetDeclaringClasshashCodenameordinaltoStringvalueOf

Field Detail

INSTANCEback to summary
public static final SingleInternalHelper.ToObservable INSTANCE

Constructor Detail

ToObservableback to summary
private ToObservable()

Method Detail

applyback to summary
public Observable<T> apply(SingleSource<T> v)

Implements io.reactivex.functions.Function.apply.

Doc from io.reactivex.functions.Function.apply.

Apply some calculation to the input value and return some other value.

Parameters
v:SingleSource<T>

the input value

Returns:Observable<T>

the output value

Annotations
@SuppressWarnings:unchecked
@Override
valueOfback to summary
public static SingleInternalHelper.ToObservable valueOf(String name)
valuesback to summary
public static SingleInternalHelper.ToObservable[] values()