reactor.rx.stream

Class RangeStream

java.lang.Object

reactor.rx.stream.RangeStream

public final class RangeStream
extends Object

A Stream that emits N Long from the inclusive start value defined to the inclusive end and then complete.

Since the stream retains the boundaries in a final field, any Subscriber will replay all the range. This is a "Cold" stream.

Create such stream with the provided factory, E.g.:

 
 Streams.range(1, 10000).consume(
    log::info,
    log::error,
    (-> log.info("complete"))
 )
 
 

 
 Will log:
 1
 2
 3
 4
 complete
 
 

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
RangeStream()

Method Summary

Modifier and Type	Method and Description
static Stream<Long>	create(long min, long max) Create a Range Stream Publisher

Methods inherited from class java.lang.Object

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

Constructor Detail

RangeStream

public RangeStream()

Method Detail

create

public static Stream<Long> create(long min,
                                  long max)

Create a Range Stream Publisher

Parameters:

min -

max -

Returns: