如何做一个轻量级的只能订阅一次的`Replay`运算符？

要实现一个轻量级的只能订阅一次的Replay运算符，可以按照以下步骤进行：

首先，需要定义一个自定义的Replay类，该类实现了Observable接口，用于创建可观察对象。
在Replay类中，需要定义一个内部缓存队列，用于存储订阅者订阅时产生的数据。
实现Replay类的subscribe方法，该方法用于订阅可观察对象。在订阅时，首先判断缓存队列是否为空，如果不为空，则将缓存队列中的数据发送给订阅者，并清空缓存队列。如果缓存队列为空，则将订阅者添加到订阅列表中。
实现Replay类的next方法，该方法用于向缓存队列中添加数据。当有新的数据产生时，将数据添加到缓存队列中，并遍历订阅列表，将数据发送给所有订阅者。
实现Replay类的unsubscribe方法，该方法用于取消订阅。当订阅者取消订阅时，将其从订阅列表中移除。

以下是一个示例代码：

class Replay:
    def __init__(self):
        self.subscribers = []
        self.cache = []

    def subscribe(self, subscriber):
        if self.cache:
            for data in self.cache:
                subscriber(data)
            self.cache = []
        else:
            self.subscribers.append(subscriber)

    def next(self, data):
        self.cache.append(data)
        for subscriber in self.subscribers:
            subscriber(data)

    def unsubscribe(self, subscriber):
        self.subscribers.remove(subscriber)

这样，我们就实现了一个轻量级的只能订阅一次的Replay运算符。可以通过创建Replay对象，然后调用subscribe方法进行订阅，调用next方法添加数据，调用unsubscribe方法取消订阅。

请注意，以上代码仅为示例，实际使用时可能需要根据具体需求进行适当的修改和扩展。