hu.akarnokd.rxjava2.internal.operators

Class PublisherIntervalOnceSource

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.PublisherIntervalOnceSource

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
PublisherIntervalOnceSource(long delay, 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

PublisherIntervalOnceSource

public PublisherIntervalOnceSource(long delay,
                                   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>