From 81ced9216c6e1a09bd1bb6836c6e72cf672e5a17 Mon Sep 17 00:00:00 2001
From: Andrea Burattin <andrea.burattin@gmail.com>
Date: Tue, 28 Dec 2021 17:04:37 +0100
Subject: [PATCH] Added constraint for response for mining algorithm

---
 .../java/beamline/models/algorithms/StreamMiningAlgorithm.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
index a7cb2c7..3960586 100644
--- a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
+++ b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
@@ -1,9 +1,10 @@
 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> implements Consumer<T> {
+public abstract class StreamMiningAlgorithm<T, K extends Response> implements Consumer<T> {
 
 	private int processedEvents = 0;
 	private K latestResponse;
-- 
GitLab