Infinite stream

Main.java

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;

/**
 * InfiniteStream.java
 * https://gist.github.com/bassemZohdy/e5fdd56de44cea3cd8ff
 * Created by sx on 26.02.16.
 */
public class Main {

    private final AtomicLong cnt = new AtomicLong();
    private void run(){
        InfiniteStream<Long> stream = new InfiniteStream<>(1);
        ExecutorService es = Executors.newCachedThreadPool();
        es.submit(()->{
            while (true){
                stream.accept(cnt.getAndIncrement());
                Thread.sleep(1);
            }
        });
        es.submit(()-> {
            stream
                    .filter(e->e%2==0)
                    .map(e->e*0.01)
                    .forEach(e-> System.out.println(e.toString()));
        });
    }

    public static void main(String[] args){
        System.out.println("RUN");
        new Main().run();
    }
}