public Stream stream()

in modules/core/src/main/java/org/apache/fluo/recipes/core/combine/InputImpl.java [51:58]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  public Stream<V> stream() {
    Stream<Bytes> bytesStream = valuesCollection.stream();
    if (currentValue != null) {
      bytesStream = Stream.concat(Stream.of(currentValue), bytesStream);
    }

    return bytesStream.map(valDeser);
  }