java async main

public static void main(String[] args) {
        CompletableFuture<Void> subTask = null;
        try (SubmissionPublisher<Long> pub = new SubmissionPublisher<>()) {
            // Create a Subscriber
            SimpleSubscriber sub = new SimpleSubscriber("S1", 10);
            // Create a processor
            FilterProcessor<Long> filter = new FilterProcessor<>(n -> n % 2 == 1);
            // Subscribe the filter to the publisher and a subscriber to the filter
            pub.subscribe(filter);  // publisher add processer          
            filter.subscribe(sub);  // processer add subscriber
            LongStream.range(1L, 10).forEach(pub::submit);
        }
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }