92 lines
2.5 KiB
Java
92 lines
2.5 KiB
Java
package appeng.me.storage;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.Iterator;
|
|
import java.util.Map.Entry;
|
|
|
|
import appeng.api.networking.security.BaseActionSource;
|
|
import appeng.api.storage.IMEInventory;
|
|
import appeng.api.storage.IMEMonitor;
|
|
import appeng.api.storage.IMEMonitorHandlerReceiver;
|
|
import appeng.api.storage.data.IAEStack;
|
|
import appeng.api.storage.data.IItemList;
|
|
import appeng.util.Platform;
|
|
import appeng.util.item.ItemList;
|
|
|
|
public class MEMonitorPassthu<T extends IAEStack<T>> extends MEPassthru<T> implements IMEMonitor<T>, IMEMonitorHandlerReceiver<T>
|
|
{
|
|
|
|
HashMap<IMEMonitorHandlerReceiver<T>, Object> listeners = new HashMap();
|
|
IMEMonitor<T> monitor;
|
|
|
|
public BaseActionSource changeSource;
|
|
|
|
public MEMonitorPassthu(IMEInventory<T> i) {
|
|
super( i );
|
|
if ( i instanceof IMEMonitor )
|
|
monitor = (IMEMonitor<T>) i;
|
|
}
|
|
|
|
@Override
|
|
public void setInternal(IMEInventory<T> i)
|
|
{
|
|
if ( monitor != null )
|
|
monitor.removeListener( this );
|
|
|
|
monitor = null;
|
|
IItemList<T> before = getInternal() == null ? new ItemList() : getInternal().getAvailableItems( new ItemList() );
|
|
|
|
super.setInternal( i );
|
|
if ( i instanceof IMEMonitor )
|
|
monitor = (IMEMonitor<T>) i;
|
|
|
|
IItemList<T> after = getInternal() == null ? new ItemList() : getInternal().getAvailableItems( new ItemList() );
|
|
|
|
if ( monitor != null )
|
|
monitor.addListener( this, monitor );
|
|
|
|
Platform.postListChanges( before, after, this, changeSource );
|
|
}
|
|
|
|
@Override
|
|
public void addListener(IMEMonitorHandlerReceiver<T> l, Object verificationToken)
|
|
{
|
|
listeners.put( l, verificationToken );
|
|
}
|
|
|
|
@Override
|
|
public void removeListener(IMEMonitorHandlerReceiver<T> l)
|
|
{
|
|
listeners.remove( l );
|
|
}
|
|
|
|
@Override
|
|
public IItemList<T> getStorageList()
|
|
{
|
|
if ( monitor == null )
|
|
return getInternal().getAvailableItems( new ItemList<T>() );
|
|
return monitor.getStorageList();
|
|
}
|
|
|
|
@Override
|
|
public boolean isValid(Object verificationToken)
|
|
{
|
|
return verificationToken == monitor;
|
|
}
|
|
|
|
@Override
|
|
public void postChange(IMEMonitor<T> monitor, T change, BaseActionSource source)
|
|
{
|
|
Iterator<Entry<IMEMonitorHandlerReceiver<T>, Object>> i = listeners.entrySet().iterator();
|
|
while (i.hasNext())
|
|
{
|
|
Entry<IMEMonitorHandlerReceiver<T>, Object> e = i.next();
|
|
IMEMonitorHandlerReceiver<T> recv = e.getKey();
|
|
if ( recv.isValid( e.getValue() ) )
|
|
recv.postChange( this, change, source );
|
|
else
|
|
i.remove();
|
|
}
|
|
}
|
|
}
|