ldbc_snb_interactive_v1_driver
ldbc_snb_interactive_v1_driver copied to clipboard
extend GeneratorFactory.limit(Iterator<T>, int) to GeneratorFactory.limit(Iterator<T>, Function<T,Boolean>)
allow arbitrary ways of defining how a stream should be limited could then implement GeneratorFactory.limit(Iterator<T>, int) using that abstraction