extracted by priority , send to intermediate stream which its last consumer extracts data correctly, all working