on method

StreamSubscription<TransmitStatus> on(
  1. String event,
  2. void callback()
)

Listen to status events.

Implementation

StreamSubscription<TransmitStatus> on(String event, void Function() callback) {
  if (event == 'connected') {
    return _statusController.stream.where((status) => status == TransmitStatus.connected).listen((_) => callback());
  } else if (event == 'disconnected') {
    return _statusController.stream
        .where((status) => status == TransmitStatus.disconnected)
        .listen((_) => callback());
  } else if (event == 'reconnecting') {
    return _statusController.stream
        .where((status) => status == TransmitStatus.reconnecting)
        .listen((_) => callback());
  }
  throw ArgumentError('Unknown event: $event');
}