在asyncio中，当使用流（Stream）时，我们需要关注以下几点：

• 读取（Read）和写入（Write）的状态必须是互斥的。也就是说，如果正在读取流，那么不能同时写入流。
• 当你尝试触发读取操作时，如果还没有读取就会抛出异常，这意味着需要确保在执行读取之前，没有其他读取正在进行中。

为了满足这些需求，asyncio中使用了'生成器协程”来实现流的操作。当一个读取操作正在进行中时，由于异步机制，可能会有其他读取操作同时进行，这可能导致无法保证流的正确性。

因此，在流中使用 _self_reading_future.future 来保证读取的同步性，使其中的读操作进行线程同步。

assert self._self_reading_future is None 判断了当前的读取操作是否已经完结，如果已经结束，则返回True，否则引发AssertionError错误。以下是asyncio中使用assert self._self_reading_future is None的代码示例：

async def read(self, n=-1): if n < 0: n = self.MAX_BUFFER_SIZE

assert self._self_reading_future is None
self._self_reading_future = asyncio.Future()
try:
    data = await self._read(n)
    return data
finally:
    self._self_reading_future.set_result(None)
    self._self_reading_future = None

我们可以看到，在读取操作开始时，我们先判断了self._self_reading_future是否已经被占用。如果已被占用，则会立即返回并抛出AssertionError错误。当读取操作完成时，会调用self._self_reading_future.set_result(None)来设置结果，并将self._self_reading_future置为None。

通过以上的代码我们可以看出，使用assert self._self_reading_future is None来保证读取的同步性，确保了读取操作不会出现重复。

建议在使用asyncio时调用.read()函数时，尽可能保证对代码进行充分的议论说明。