Refactoring to make NodeRunnable attached to Stream instead of Flow