public void accept()

in mobius-core/src/main/java/com/spotify/mobius/MessageDispatcher.java [47:62]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  public void accept(final M message) {
    if (disposed) {
      return;
    }

    runner.post(
        () -> {
          try {
            consumer.accept(message);
          } catch (Throwable throwable) {
            MobiusHooks.handleError(
                new RuntimeException(
                    "Consumer threw an exception when accepting message: " + message, throwable));
          }
        });
  }