test.java

///usr/bin/env jbang "$0" "$@" ; exit $?
//DEPS https://github.com/maxandersen/fluent-process/tree/shell

import java.util.stream.Collectors;
import java.util.stream.Stream;
import static com.ongres.process.FluentProcess.$;

public class test {

    public static void main(String... args) {
        $("ls -l | wc -l")
                .inputStream(Stream.of("hello", "world"))
                .pipe$("sed 's/world/process/'")
                .stream()
                .peek(System.out::println)
                .collect(Collectors.toList());

    }
}

test.jsh

///usr/bin/env jbang "$0" "$@" ; exit $?
//DEPS https://github.com/maxandersen/fluent-process/tree/shell

import java.util.stream.Collectors;
import java.util.stream.Stream;
import static com.ongres.process.FluentProcess.$;

{
        $("ls -l | wc -l")
                .inputStream(Stream.of("hello", "world"))
                .pipe$("sed 's/world/process/'")
                .stream()
                .peek(System.out::println)
                .collect(Collectors.toList());
}