public Disposable subscribe()

in mobius-core/src/main/java/com/spotify/mobius/MergedEventSource.java [55:69]

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

  public Disposable subscribe(Consumer<E> eventConsumer) {
    final List<Disposable> disposables = new ArrayList<>(eventSources.size());
    for (EventSource<E> eventSource : eventSources) {
      disposables.add(eventSource.subscribe(eventConsumer));
    }

    return new Disposable() {
      @Override
      public void dispose() {
        for (Disposable disposable : disposables) {
          disposable.dispose();
        }
      }
    };
  }