Removed stream usage from TimerExecutor.

This commit is contained in:
MobiusDevelopment 2023-01-08 12:47:48 +00:00
parent cb79b5f792
commit c38dcc2b28
26 changed files with 442 additions and 52 deletions

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**

View File

@ -172,7 +172,13 @@ public class TimerExecutor<T>
*/
public void cancelAllTimers()
{
_timers.values().stream().flatMap(Set::stream).forEach(TimerHolder::cancelTimer);
for (Set<TimerHolder<T>> set : _timers.values())
{
for (TimerHolder<T> timer : set)
{
timer.cancelTimer();
}
}
_timers.clear();
}
@ -189,7 +195,16 @@ public class TimerExecutor<T>
{
return false;
}
return timers.stream().anyMatch(holder -> holder.isEqual(event, npc, player));
for (TimerHolder<T> holder : timers)
{
if (holder.isEqual(event, npc, player))
{
return true;
}
}
return false;
}
/**