রিঅ্যাক্টিভ স্টেট প্যাটার্ন — স্ট্রিম ও অবজার্ভেবল

# একটি সত্যিকারের Stream/Observable -- subscribe() ও emit()

class Stream:
    def __init__(self):
        self._subscribers = []

    def subscribe(self, callback):
        self._subscribers.append(callback)
        return callback

    def emit(self, value):
        for callback in self._subscribers:
            callback(value)


# উদাহরণ: একটি এক্সিলারোমিটার সেন্সরের র (raw) রিডিং-এর ধারা
raw_shake_events = Stream()

received = []
raw_shake_events.subscribe(lambda v: received.append(v))

raw_shake_events.emit(0.2)
raw_shake_events.emit(0.5)
raw_shake_events.emit(9.8)

print(f"সাবস্ক্রাইবার যা যা পেয়েছে: {received}")

class Stream:
    def __init__(self):
        self._subscribers = []

    def subscribe(self, callback):
        self._subscribers.append(callback)
        return callback

    def emit(self, value):
        for callback in self._subscribers:
            callback(value)

    def map(self, fn):
        mapped_stream = Stream()

        def relay(raw_value):
            mapped_stream.emit(fn(raw_value))

        self.subscribe(relay)
        return mapped_stream


def fahrenheit_to_celsius(f):
    return round((f - 32) * 5 / 9, 2)


# র তাপমাত্রা-সেন্সর রিডিং (ফারেনহাইট) -- ডিভাইসের একটি বহিরাগত তাপ-সেন্সর থেকে
raw_temp_stream = Stream()

# ধাপ ১: সেলসিয়াসে রূপান্তরিত একটি নতুন, স্বতন্ত্র স্ট্রিম
celsius_stream = raw_temp_stream.map(fahrenheit_to_celsius)

# ধাপ ২: সেলসিয়াস স্ট্রিমকে আবার ম্যাপ করে জ্বর-সতর্কতা (বুলিয়ান) স্ট্রিম -- .map() চেইন করা
fever_alert_stream = celsius_stream.map(lambda c: c > 37.0)

received_raw = []
received_celsius = []
received_fever_alert = []

raw_temp_stream.subscribe(lambda v: received_raw.append(v))
celsius_stream.subscribe(lambda v: received_celsius.append(v))
fever_alert_stream.subscribe(lambda v: received_fever_alert.append(v))

for reading_f in [98.6, 100.4, 68.0]:
    print(f"র সেন্সর রিডিং এমিট হলো: {reading_f}°F")
    raw_temp_stream.emit(reading_f)

print(f"\nraw_temp_stream-এর সাবস্ক্রাইবার যা পেয়েছে (অপরিবর্তিত র মান): {received_raw}")
print(f"celsius_stream-এর সাবস্ক্রাইবার যা পেয়েছে (ট্রান্সফর্মড, °C): {received_celsius}")
print(f"fever_alert_stream-এর সাবস্ক্রাইবার যা পেয়েছে (দ্বিগুণ-ট্রান্সফর্মড, বুলিয়ান): {received_fever_alert}")

proof = received_celsius == [37.0, 38.0, 20.0] and received_fever_alert == [False, True, False]
print(f"\nপ্রমাণ -- মূল স্ট্রিমে দেওয়া র °F মান নয়, বরং প্রতিটি ধাপে ট্রান্সফর্মড মানই সাবস্ক্রাইবার পেয়েছে: {proof}")
assert proof