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

Removed requirement for Response in returned value from stream mining

algorithm
parent e58eeac1
No related branches found
No related tags found
No related merge requests found
...@@ -4,7 +4,7 @@ ...@@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>beamline</groupId> <groupId>beamline</groupId>
<artifactId>framework</artifactId> <artifactId>framework</artifactId>
<version>0.0.1</version> <version>0.0.2</version>
<properties> <properties>
<maven.compiler.source>11</maven.compiler.source> <maven.compiler.source>11</maven.compiler.source>
......
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 extends Response> implements Consumer<T> { public abstract class StreamMiningAlgorithm<T, K> 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.
Finish editing this message first!
Please register or to comment