Main.java

public static Closeable smoothInterrupt(Plugin plugin, BiConsumer<Player, Block> interruptions) {
		final Map<Player, BukkitTask> tasks = new HashMap<>();
		PacketAdapter adapter = new PacketAdapter(plugin, BLOCK_DIG) {
			@Override
			public void onPacketReceiving(PacketEvent event) {
				Player player = event.getPlayer();
				Block block = event.getPacket()
						.getBlockPositionModifier().read(0)
						.toLocation(player.getWorld()).getBlock();
				
				switch (event.getPacket().getPlayerDigTypes().getValues().get(0)) {
					case START_DESTROY_BLOCK: {
						tasks.compute(player, ($, task) -> {
							if (task != null)
								task.cancel();
							return getScheduler().runTaskLater(plugin, () -> {
								interruptions.accept(player, block);
								tasks.remove(player);
							}, getBreakTime(player, block));
						});
						break;
					}
					case ABORT_DESTROY_BLOCK:
					case STOP_DESTROY_BLOCK: {
						BukkitTask remove = tasks.remove(player);
						if (remove != null)
							remove.cancel();
					}
				}
			}
		};
		getProtocolManager().addPacketListener(adapter);
		return () -> {
			getProtocolManager().removePacketListener(adapter);
		};
	}