hu.akarnokd.rxjava2.internal.operators

Class PublisherIterableSource<T>

java.lang.Object

java.util.concurrent.atomic.AtomicBoolean

hu.akarnokd.rxjava2.internal.operators.PublisherIterableSource<T>

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Publisher<T>

public final class PublisherIterableSource<T>
extends java.util.concurrent.atomic.AtomicBoolean
implements org.reactivestreams.Publisher<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PublisherIterableSource(java.lang.Iterable<? extends T> source)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super T> s)

Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PublisherIterableSource

public PublisherIterableSource(java.lang.Iterable<? extends T> source)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super T> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>