working stream implementation