Added transducer which emits a value at beginning of processing.