From e249444217fdb063474b997217a2ea856442b7d7 Mon Sep 17 00:00:00 2001 From: Andrea Burattin <andrea.burattin@gmail.com> Date: Wed, 29 Dec 2021 17:10:59 +0100 Subject: [PATCH] Removed requirement for Response in returned value from stream mining algorithm --- pom.xml | 2 +- .../java/beamline/models/algorithms/StreamMiningAlgorithm.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/pom.xml b/pom.xml index 71f538e..d6f1649 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ <modelVersion>4.0.0</modelVersion> <groupId>beamline</groupId> <artifactId>framework</artifactId> - <version>0.0.1</version> + <version>0.0.2</version> <properties> <maven.compiler.source>11</maven.compiler.source> diff --git a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java index 3960586..a7cb2c7 100644 --- a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java +++ b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java @@ -1,10 +1,9 @@ package beamline.models.algorithms; -import beamline.models.responses.Response; import io.reactivex.rxjava3.annotations.NonNull; 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 K latestResponse; -- GitLab