RxCommand.createFromStream() emits a exception twice.

[baku-apps]

    var command = RxCommand.createFromStream((_) {
      return Observable.just('test').map((rideMap) {
        throw Exception();
      });
    });

    command.thrownExceptions.listen((e) {
      print(e.toString()); //--> prints twice
    });

    command.execute();

This prints the exception twice. I would expect it to print it only once.

[escamoteur]

Thanks for reporting
Fixed in 4.3.4