Calling 'subscribe' in "reactive" methods

Reports subscribe() calls in "reactive" methods.

Methods returning a publisher (including Uni and Multi) should not call the subscribe() method directly because it can break the reactive call chain.

Instead of using subscribe(), consider using composition operators like flatMap(), merge(), and so on.

Example:

  Multi<String> stringMulti(){
    Multi<String> multi = Multi.createFrom().item("abc");
    multi.subscribe(); // <- blocking 'subscribe' call in non-blocking context
    return multi;
  }

Locating this inspection

By ID

Can be used to locate inspection in e.g. Qodana configuration files, where you can quickly enable or disable it, or adjust its settings.

MutinyCallingSubscribeInNonBlockingScope

Via Settings dialog

Path to the inspection settings via IntelliJ Platform IDE Settings dialog, when you need to adjust inspection settings directly from your IDE.

Settings or Preferences | Editor | Inspections | Reactive Streams | Mutiny

Availability

By default bundled with: IntelliJ IDEA 2024.1, Qodana for JVM 2024.1,
Can be installed with plugin: Reactive Streams, 241.18072

Last modified: 18 June 2024