[streaming] explicit fail function and AckerTaskTest wip