def _flush_buffer(self): # New logic: Ensure stream is writable before writing if not self.stream.writable: raise StreamError("Cannot write to closed stream") while self.buffer: packet = self.buffer.pop(0) self.stream.write(packet) # Force sync self.stream.end() A specific test case must be added to regression-proof this fix. Beataporn Beata Undine Morning Joy All Se Patched Review
src/rafian/core/connection_manager.py (or equivalent language) Wonder Woman Vs Warlord Part 2 Hot Apr 2026
Fixes #51
def on_disconnect(self, event): logging.warning(f"Connection lost. Issue #51 handling initiated.") self.is_connected = False # Preserve current buffer state to prevent data loss self._persist_buffer_to_temp_storage()
class ConnectionManager: def __init__(self): self.buffer = [] self.is_connected = False self.retry_count = 0