cleanup and fixed small newBreaks issue

Author: beanbag44

common/src/main/kotlin/com/lambda/interaction/request/breaking/BreakManager.kt

@@ -285,22 +285,24 @@ object BreakManager : RequestHandler<BreakRequest>(), PositionBlocking {
 
     private fun refreshOrCancelBreaks(newContexts: MutableCollection<BreakContext>, request: BreakRequest) {
         breakInfos
-            .forEachNotNull { info ->
+            .filterNotNull()
+            .forEach { info ->
                 newContexts.find { ctx -> ctx.expectedPos == info.context.expectedPos }?.let { ctx ->
                     info.updateInfo(ctx, request)
                     newContexts.remove(ctx)
-                    return@forEachNotNull
+                    return@forEach
                 }
 
                 info.cancelBreak()
             }
     }
 
-    private fun SafeContext.processNewBreaks(newBreaks: Collection<BreakContext>, request: BreakRequest) {
+    private fun SafeContext.processNewBreaks(newBreaks: MutableCollection<BreakContext>, request: BreakRequest) {
         newBreaks
             .filter { !it.instantBreak }
             .forEach { ctx ->
                 handleNewBreak(ctx, request) ?: return
+                newBreaks.remove(ctx)
                 request.onAccept?.invoke(ctx.expectedPos)
                 if (atMaxBreakInfos(request.buildConfig.breakSettings)) return
             }
@@ -365,7 +367,7 @@ object BreakManager : RequestHandler<BreakRequest>(), PositionBlocking {
     }
 
     private fun setPendingBreaksLimits(buildConfig: BuildConfig) {
-        pendingBreaks.setMaxSize(buildConfig.breakSettings.maxPendingBreaks)
+        pendingBreaks.setSizeLimit(buildConfig.breakSettings.maxPendingBreaks)
         pendingBreaks.setDecayTime(buildConfig.interactionTimeout * 50L)
     }
 
@@ -621,10 +623,6 @@ object BreakManager : RequestHandler<BreakRequest>(), PositionBlocking {
             else -> secondaryBreak = null
         }
 
-    private fun Array<BreakInfo?>.forEachNotNull(block: (BreakInfo) -> Unit) {
-        for (info in this) info?.run(block)
-    }
-
     override fun preEvent() = UpdateManagerEvent.Break.Pre().post()
     override fun postEvent() = UpdateManagerEvent.Break.Post().post()
 }

common/src/main/kotlin/com/lambda/interaction/request/placing/PlaceManager.kt

@@ -176,7 +176,7 @@ object PlaceManager : RequestHandler<PlaceRequest>(), PositionBlocking {
             val placeConfig = request.buildConfig.placeSettings
 
             if (tickPre) {
-                pendingPlacements.setMaxSize(placeConfig.maxPendingPlacements)
+                pendingPlacements.setSizeLimit(placeConfig.maxPendingPlacements)
                 pendingPlacements.setDecayTime(request.buildConfig.interactionTimeout * 50L)
 
                 val isSneaking = player.isSneaking