purge method

@override Future<int> purge(String queue)

Remove every message, returning how many went.

Implementation

@override
Future<int> purge(String queue) async {
  _send(1, _channel, <int>[
    ..._u16(50), ..._u16(30), // Queue.Purge
    ..._u16(0),
    ..._shortString(queue),
    0,
  ]);
  final _Frame reply = await _next();
  return reply.payload.buffer.asByteData().getUint32(4);
}