code: async def message_throttled(self, message: types.Message, throttled: Throttled):
          
          handler = current_handler.get()
          dispatcher = Dispatcher.get_current()
          if handler:
              key = getattr(handler, 'throttling_key', f"{self.prefix}_{handler.__name__}")
          else:
              key = f"{self.prefix}_message"
  
          # Calculate how many time is left till the block ends
          delta = throttled.rate - throttled.delta
  
          # Prevent flooding
          if throttled.exceeded_count <= 2:
              await message.reply('Too many requests! ')
  
          # Sleep.
          await asyncio.sleep(delta)
  
          # Check lock status
          thr = await dispatcher.check_key(key)
  
          # If current message is not last with current key - do not send message
          if thr.exceeded_count == throttled.exceeded_count:
              await message.reply('Unlocked.')
docs: Notify user only on first exceed and notify about unlocking only on last exceed
  
          :param message:
          :param throttled: