new prcoessing flow and streams2-like api.