trying to use concurrent.buffer...