hu.akarnokd.rxjava2.internal.operators

Class PublisherIntervalRangeSource

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.PublisherIntervalRangeSource

All Implemented Interfaces:

org.reactivestreams.Publisher<java.lang.Long>

public final class PublisherIntervalRangeSource
extends java.lang.Object
implements org.reactivestreams.Publisher<java.lang.Long>

Constructor Summary

Constructors

Constructor and Description
PublisherIntervalRangeSource(long start, long end, long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherIntervalRangeSource

public PublisherIntervalRangeSource(long start,
                                    long end,
                                    long initialDelay,
                                    long period,
                                    java.util.concurrent.TimeUnit unit,
                                    Scheduler scheduler)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super java.lang.Long> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<java.lang.Long>