Internal Stream API - draft