// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.eventbus.server;

import org.litesoft.GWT.eventbus.client.*;

import java.util.*;

public class ServerEventBusSubscriptionCollector extends EventSubscriptionCollector {
    public synchronized void addListener( ServerEventBusDisposeListener pServerEventBusDisposeListener ) {
        if ( pServerEventBusDisposeListener != null ) {
            mListeners.add( pServerEventBusDisposeListener );
        }
    }

    /**
     * @return !null, and no nulls in array
     */
    public final synchronized ServerEventBusDisposeListener[] getListeners() {
        if ( mListeners.isEmpty() ) {
            return ServerEventBusDisposeListener.EMPTY_ARRAY;
        }
        ServerEventBusDisposeListener[] rv = new ServerEventBusDisposeListener[mListeners.size()];
        int i = 0;
        for ( ServerEventBusDisposeListener zListener : mListeners ) {
            rv[i++] = zListener;
        }
        return rv;
    }

    private Set<ServerEventBusDisposeListener> mListeners = new HashSet<ServerEventBusDisposeListener>();
}