Removing Subscription results in RuntimeError

[siebentausend]

Hi!
First of all - great approach and very helpful project! Unfortunately, trying to remove a subscription I run into the following error:

netaudio subscription remove --rx-channel-name=CH01 --rx-device-name=Monitor

  RuntimeError

  coroutine raised StopIteration

  at /usr/lib/python3.11/asyncio/base_events.py:653 in run_until_complete
       649│             future.remove_done_callback(_run_until_complete_cb)
       650│         if not future.done():
       651│             raise RuntimeError('Event loop stopped before Future completed.')
       652│ 
    →  653│         return future.result()
       654│ 
       655│     def stop(self):
       656│         
       657│ 

Is it me doing it wrong? Not sure if it makes a difference, but it's a Multicast subscription.

[chris-ritsen]

It's been a while since I've tested this feature. I'll look into it.

[siebentausend]

Great! Big thanks!

[AnnoyingTechnology]

Hi @chris-ritsen any update on this ?

OP is on python 3.11
I tried python3.13 and 3.10 with the following results.

$ netaudio subscription list
CH1@XLR-SMSL-BEDROOM <- CH1@AES-EBU-MINIDSP [Connected (Unicast)]
CH2@XLR-SMSL-BEDROOM <- CH2@AES-EBU-MINIDSP [Connected (Unicast)]
CH1@AES-EBU-MINIDSP <- Left@USBC-LAPTOP [Connected (Unicast)]
CH2@AES-EBU-MINIDSP <- Right@USBC-LAPTOP [Connected (Unicast)]

>> netaudio subscription remove --rx-device-name AES-EBU-MINIDSP --rx-channel-number 1

  RuntimeError

  coroutine raised StopIteration

  at ~/miniconda3/envs/netaudio/lib/python3.10/asyncio/base_events.py:649 in run_until_complete
       645│             future.remove_done_callback(_run_until_complete_cb)
       646│         if not future.done():
       647│             raise RuntimeError('Event loop stopped before Future completed.')
       648│ 
    →  649│         return future.result()
       650│ 
       651│     def stop(self):
       652│         
       653│ 

same with --rx-channel-number CH1

[AnnoyingTechnology]

It's odd. In verbose mode, it complains about a non existant --rx-device-name option.

$ netaudio -vvv subscription remove --rx-device-name AES-EBU-MINIDSP --rx-channel-number 2

  Stack trace:

  10  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/console_application.py:127 in run
       125│             )  # type: IO
       126│ 
     → 127│             resolved_command = self.resolve_command(args)
       128│             command = resolved_command.command
       129│             parsed_args = resolved_command.args

   9  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/console_application.py:110 in resolve_command
       108│                 return resolved_command
       109│ 
     → 110│         return self._config.command_resolver.resolve(args, self)
       111│ 
       112│     def run(

   8  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/resolver/default_resolver.py:43 in resolve
        41│ 
        42│         # If no arguments were passed, run the application's default command.
     →  43│         result = self.process_default_commands(args, application.default_commands)
        44│         if result:
        45│             return self.create_resolved_command(result)

   7  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/resolver/default_resolver.py:104 in process_default_commands
       102│             resolved_command = ResolveResult(default_command, args)
       103│ 
     → 104│             if resolved_command.is_parsable():
       105│                 return resolved_command
       106│ 

   6  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/resolver/resolve_result.py:43 in is_parsable
       41│     def is_parsable(self):  # type: () -> bool
       42│         if not self._parsed:
     → 43│             self._parse()
       44│ 
       45│         return self.parse_error is None

   5  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/resolver/resolve_result.py:49 in _parse
       47│     def _parse(self):  # type: () -> None
       48│         try:
     → 49│             self._parsed_args = self._command.parse(self._raw_args)
       50│         except CannotParseArgsException as e:
       51│             self._parse_error = e

   4  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/api/command/command.py:113 in parse
       111│             lenient = self._config.is_lenient_args_parsing_enabled()
       112│ 
     → 113│         return self._config.args_parser.parse(args, self._args_format, lenient)
       114│ 
       115│     def run(self, args, io):  # type: (RawArgs, IO) -> int

   3  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/args/default_args_parser.py:53 in parse
        51│ 
        52│         try:
     →  53│             self._parse(args, _fmt, lenient)
        54│         except (CannotParseArgsException, NoSuchOptionException):
        55│             if not lenient:

   2  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/args/default_args_parser.py:101 in _parse
        99│                 parse_options = False
       100│             elif parse_options and token.find("--") == 0:
     → 101│                 self._parse_long_option(token, tokens, fmt, lenient)
       102│             elif parse_options and token[0] == "-" and token != "-":
       103│                 self._parse_short_option(token, tokens, fmt, lenient)

   1  ~/miniconda3/envs/netaudio/lib/python3.10/site-packages/clikit/args/default_args_parser.py:247 in _parse_long_option
       245│                 self._add_long_option(name, value, tokens, fmt, lenient)
       246│             else:
     → 247│                 self._add_long_option(name, None, tokens, fmt, lenient)
       248│ 
       249│     def _parse_short_option(

  NoSuchOptionException

  The "--rx-device-name" option does not exist.