@@ -0,0 +1,743 @@
+package io.jenetics.example.timeseries;%0A%0Aimport java.util.concurrent.SubmissionPublisher;%0Aimport java.util.concurrent.atomic.AtomicBoolean;%0A%0Aimport io.jenetics.Gene;%0Aimport io.jenetics.engine.EvolutionResult;%0Aimport io.jenetics.engine.EvolutionStream;%0A%0Apublic class EvolutionPublisher%3C%0A%09G extends Gene%3C?, G%3E,%0A%09C extends Comparable%3C? super C%3E%0A%3E%0A%09extends SubmissionPublisher%3CEvolutionResult%3CG, C%3E%3E%0A%7B%0A%0A%09private final EvolutionStream%3CG, C%3E _stream;%0A%0A%09private final AtomicBoolean _proceed = new AtomicBoolean(true);%0A%0A%09public EvolutionPublisher(final EvolutionStream%3CG, C%3E stream) %7B%0A%09%09_stream = stream.limit(er -%3E _proceed.get());%0A%09%09_stream.forEach(this::submit);%0A%09%7D%0A%0A%09@Override%0A%09public void close() %7B%0A%09%09_proceed.set(false);%0A%09%09super.close();%0A%09%7D%0A%0A%0A%7D%0A

Add 'EvolutionPublisher' class.