mobius-core/src/main/java/com/spotify/mobius/DiscardAfterDisposeConnectable.java [38:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
class DiscardAfterDisposeConnectable<I, O> implements Connectable<I, O> {

  private final Connectable<I, O> actual;

  DiscardAfterDisposeConnectable(Connectable<I, O> actual) {
    this.actual = checkNotNull(actual);
  }

  @Nonnull
  @Override
  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();
      }
    };
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mobius-rx2/src/main/java/com/spotify/mobius/rx2/DiscardAfterDisposeConnectable.java [40:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
class DiscardAfterDisposeConnectable<I, O> implements Connectable<I, O> {

  private final Connectable<I, O> actual;

  DiscardAfterDisposeConnectable(Connectable<I, O> actual) {
    this.actual = checkNotNull(actual);
  }

  @Nonnull
  @Override
  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();
      }
    };
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -