Skip to content
Snippets Groups Projects
Commit 81ced921 authored by Andrea Burattin's avatar Andrea Burattin
Browse files

Added constraint for response for mining algorithm

parent 9ba07004
No related branches found
No related tags found
No related merge requests found
package beamline.models.algorithms; package beamline.models.algorithms;
import beamline.models.responses.Response;
import io.reactivex.rxjava3.annotations.NonNull; import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.functions.Consumer; import io.reactivex.rxjava3.functions.Consumer;
public abstract class StreamMiningAlgorithm<T, K> implements Consumer<T> { public abstract class StreamMiningAlgorithm<T, K extends Response> implements Consumer<T> {
private int processedEvents = 0; private int processedEvents = 0;
private K latestResponse; private K latestResponse;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment