package com.nisum.subscriptions;
import com.nisum.subscribers.EventSubscriber;

import java.util.concurrent.SubmissionPublisher;

public class SubscriptionBehaviour {
    public static void main(String[] args) throws InterruptedException {

        SubmissionPublisher<Integer> feed=new SubmissionPublisher<>();
        EventSubscriber eventSubscriber=new EventSubscriber();
        feed.subscribe(eventSubscriber);

        for (int i = 1; i <= 10; i++) {
            feed.submit(i);
        }
        sleep(1000);
    }




    private static Boolean sleep(int ms) {
        try{
            Thread.sleep(ms);
            return true;
        }
        catch(InterruptedException e){
            return false;
        }
    }


}