Return to Question

Adding How to use it:

public static void main(String[] args) {
    InfiniteStream<Integer> is = new InfiniteStream<Integer>(10);
    CompletableFuture.runAsync(() -> {
        while (true) {
            try {
                Thread.sleep(1000);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
            IntStream.range(0, 100).boxed().forEach(is);
        }
    });
    is.forEach(System.out::println);
}

I did InfiniteStream by implementing Stream and Consumer. You can initiate the stream then consume an object using it. I've dded queueing for it to handle storing more than one value from accept. Please provide feedback.

I did InfiniteStream by implementing Stream and Consumer. You can initiate the stream then consume an object using it. I've added queueing for it to handle storing more than one value from accept. Please provide feedback.

I did InfiniteStream by implementing Stream and Consumer so you can initiate the stream then consume object using it, and added queueing for it to handle storing more than one value from accept please send me your feedback:

I did InfiniteStream by implementing Stream and Consumer. You can initiate the stream then consume an object using it. I've dded queueing for it to handle storing more than one value from accept. Please provide feedback.