Logging 'queue drained' after finishing the stream - Effect Community