com.github.davidmoten.rx2

Class Flowables.MergeInterleaveBuilder<T>

java.lang.Object

com.github.davidmoten.rx2.Flowables.MergeInterleaveBuilder<T>

Enclosing class:

Flowables

public static final class Flowables.MergeInterleaveBuilder<T>
extends Object

Method Summary

Modifier and Type	Method and Description
Flowables.MergeInterleaveBuilder<T>	batchSize(int batchSize)
io.reactivex.Flowable<T>	build()
Flowables.MergeInterleaveBuilder<T>	delayErrors(boolean delayErrors)
Flowables.MergeInterleaveBuilder<T>	maxConcurrency(int maxConcurrency)

Methods inherited from class java.lang.Object

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

Method Detail

maxConcurrency

public Flowables.MergeInterleaveBuilder<T> maxConcurrency(int maxConcurrency)

batchSize

public Flowables.MergeInterleaveBuilder<T> batchSize(int batchSize)

delayErrors

public Flowables.MergeInterleaveBuilder<T> delayErrors(boolean delayErrors)

build

public io.reactivex.Flowable<T> build()