hu.akarnokd.rxjava2.internal.operators

Class PublisherIntervalSource

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.PublisherIntervalSource

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
PublisherIntervalSource(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

PublisherIntervalSource

public PublisherIntervalSource(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>