Fixed producer bug with closing prematurely