Fix tests.

This commit is contained in:
Fabian Märki
2016-01-26 11:20:47 +01:00
parent e4651fcb4d
commit faab4fb439

View File

@ -254,7 +254,12 @@ public class DummyCassandraReader implements CassandraReader {
i -> i * 10, i -> i * 10,
i -> 0, i -> 0,
i -> i, i -> i,
query.getChannel()).stream(); query.getChannel())
.stream()
.map(metaPulse -> {
metaPulse.setKeyspace(KEYSPACE);
return metaPulse;
});
} }
/** /**