From faab4fb43903db6c02e63761c71d024852b493e3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fabian=20M=C3=A4rki?= Date: Tue, 26 Jan 2016 11:20:47 +0100 Subject: [PATCH] Fix tests. --- .../psi/daq/test/queryrest/query/DummyCassandraReader.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java index 715fd2a..769e035 100644 --- a/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java +++ b/src/test/java/ch/psi/daq/test/queryrest/query/DummyCassandraReader.java @@ -254,7 +254,12 @@ public class DummyCassandraReader implements CassandraReader { i -> i * 10, i -> 0, i -> i, - query.getChannel()).stream(); + query.getChannel()) + .stream() + .map(metaPulse -> { + metaPulse.setKeyspace(KEYSPACE); + return metaPulse; + }); } /**