Interface VirtualGenerator<T>

Type Parameters:

T - the element type generated

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface VirtualGenerator<T>

Interface to implement to produce elements when asked by Flowable.virtualCreate(VirtualGenerator, java.util.concurrent.ExecutorService).

To signal onComplete, return normally from generate(VirtualEmitter). To signal onError, throw any exception from generate(VirtualEmitter).

Since:

4.0.0

Method Summary

Modifier and Type	Method	Description
void	generate(VirtualEmitter<T> emitter)	The method to implement and start emitting items.

Method Details

generate

void generate(VirtualEmitter<T> emitter)
       throws Throwable

The method to implement and start emitting items.

Parameters:

emitter - use VirtualEmitter.emit(Object) to generate values

Throws:

Throwable - if the generator wishes to signal onError.