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

import java.util.*;

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

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>();
}