package com.nbusy.app.event;


public class EventBus {
}

// guava async event bus way of doing this...
/*EventBus eventBus = new AsyncEventBus(new Executor() {

    private Handler mHandler;

    @Override
    public void execute(Runnable command) {
        if (mHandler == null) {
        // post events to handlers on the UI thread
            mHandler = new Handler(Looper.getMainLooper());
        }
        mHandler.post(command);
    }
});*/

@@ -29,33 +29,334 @@
 %0D%0A%0D%0A
-%0D%0Apublic class EventBus %7B
+import java.util.concurrent.ExecutorService;%0D%0Aimport java.util.concurrent.Executors;%0D%0A%0D%0Apublic class EventBus %7B%0D%0A    private final ExecutorService pool;%0D%0A%0D%0A    public EventBus(int poolSize) %7B%0D%0A        // actually we need to adjust pools based on batch/group sizes%0D%0A        pool = Executors.newFixedThreadPool(poolSize);%0D%0A    %7D
 %0D%0A%7D%0D

add sample ex. svc