new processing flow and streams2-like api.