transformStreams method

Stream<T> transformStreams(Map<StreamNode, Stream> existingStreams)

Implementation

Stream<T> transformStreams(Map<StreamNode, Stream> existingStreams) =>
    (existingStreams[input]! as Stream<T>).where(predicate);