dispose method

void dispose()

Stop listening for new messages and cancel all active subscriptions

Implementation

void dispose() {
  _processor.dispose();
}