public static Connectable merge()

in mobius-extras/src/main/java/com/spotify/mobius/extras/Connectables.java [184:199]

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

  public static <A, B> Connectable<A, B> merge(
      final Connectable<A, B> fst, final Connectable<A, B> snd, final Connectable<A, B>... cs) {
    return SimpleConnectable.withConnectionFactory(
        new Function<Consumer<B>, Connection<A>>() {
          @Nonnull
          @Override
          public Connection<A> apply(Consumer<B> output) {
            final ArrayList<Connectable<A, B>> connectables = new ArrayList<>(cs.length + 2);
            connectables.add(fst);
            connectables.add(snd);
            Collections.addAll(
                connectables, (Connectable<A, B>[]) Preconditions.checkArrayNoNulls(cs));
            return MergeConnectablesConnection.create(connectables, output);
          }
        });
  }