No, it is just my thinking why you get a failure with transformer.isComplete. Usually the conditions of a TransferPhase should be external async events (demand, input, completion, etc.) while isComplete is not external since we drive the transformer directly. You said that without this condition the test fails which drove me in the direction that probably the parent class (TransformProcessorImpl) does something which completes this earlier than you want.