package im.vector;


import android.os.Handler;
import android.os.Looper;

import org.matrix.androidsdk.util.Log;

import java.util.HashSet;
import java.util.Set;

public class EventEmitter<T> {
    private static final String LOG_TAG = EventEmitter.class.getSimpleName();

    private final Set<Listener<T>> mCallbacks;
    private final Handler mUiHandler;

    public EventEmitter() {
        mCallbacks = new HashSet<>();
        mUiHandler = new Handler(Looper.getMainLooper());
    }

    public void register(Listener<T> cb) {
        mCallbacks.add(cb);
    }

    public void unregister(Listener<T> cb) {
        mCallbacks.remove(cb);
    }

    /**
     * Fires all registered callbacks on the UI thread.
     *
     * @param t
     */
    public void fire(final T t) {
        final Set<Listener<T>> callbacks = new HashSet<>(mCallbacks);

        mUiHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                for (Listener<T> cb : callbacks) {
                                    try {
                                        cb.onEventFired(EventEmitter.this, t);
                                    } catch (Exception e) {
                                        Log.e(LOG_TAG, "Callback threw: " + e.getMessage(), e);
                                    }
                                }
                            }
                        }
        );
    }

    public interface Listener<T> {
        void onEventFired(EventEmitter<T> emitter, T t);
    }
}

package im.vector;

import android.os.Handler;
import android.os.Looper;

import org.matrix.androidsdk.util.Log;

import java.util.HashSet;
import java.util.Set;

public class EventEmitter<T> {
    private static final String LOG_TAG = EventEmitter.class.getSimpleName();

    private final Set<Listener<T>> mCallbacks;
    private final Handler mUiHandler;

    public EventEmitter() {
        mCallbacks = new HashSet<>();
        mUiHandler = new Handler(Looper.getMainLooper());
    }

    public void register(Listener<T> cb) {
        mCallbacks.add(cb);
    }

    public void unregister(Listener<T> cb) {
        mCallbacks.remove(cb);
    }

    /**
     * Fires all registered callbacks on the UI thread.
     *
     * @param t passed to the callback
     */
    public void fire(final T t) {
        final Set<Listener<T>> callbacks = new HashSet<>(mCallbacks);

        mUiHandler.post(new Runnable() {
                            @Override
                            public void run() {
                                for (Listener<T> cb : callbacks) {
                                    try {
                                        cb.onEventFired(EventEmitter.this, t);
                                    } catch (Exception e) {
                                        Log.e(LOG_TAG, "Callback threw: " + e.getMessage(), e);
                                    }
                                }
                            }
                        }
        );
    }

    public interface Listener<T> {
        void onEventFired(EventEmitter<T> emitter, T t);
    }
}

Add parameter documentation to the even emitter
Add parameter documentation to the even emitter
