async def _push(self, *args, **kwargs):
self._data.append((args, kwargs))<EOL>if self._future is not None:<EOL><INDENT>future, self._future = self._future, None<EOL>future.set_result(True)<EOL><DEDENT>
Push new data into the buffer. Resume looping if paused.