public Connection connect()

in mobius-rx2/src/main/java/com/spotify/mobius/rx2/DiscardAfterDisposeConnectable.java [50:68]

• 16 lines of code
• 1 McCabe index (conditional complexity)

  public Connection<I> connect(Consumer<O> output) {
    final DiscardAfterDisposeWrapper<O> safeOutput = wrapConsumer(output);
    final Connection<I> input = actual.connect(safeOutput);
    final DiscardAfterDisposeWrapper<I> safeInput = wrapConnection(input);

    final Disposable disposable = CompositeDisposable.from(safeInput, safeOutput);

    return new Connection<I>() {
      @Override
      public void accept(I effect) {
        safeInput.accept(effect);
      }

      @Override
      public void dispose() {
        disposable.dispose();
      }
    };
  }