read_nonblock instead of readpartial
fiber based dsl works
consumers work correctly now