50 lines
1.1 KiB
Python
50 lines
1.1 KiB
Python
import threading
|
|
from chunks import ChunkPool
|
|
|
|
class ClientChunkPool(ChunkPool):
|
|
"""
|
|
A ChunkPool that requests/loads chunks from a client.
|
|
"""
|
|
|
|
def __init__(self, client):
|
|
super().__init__()
|
|
|
|
self._client = client
|
|
self._save_thread = None
|
|
|
|
def set(self, pos, chunk):
|
|
super().set(pos, chunk)
|
|
|
|
def apply_changes(self, changes):
|
|
super().apply_changes(changes)
|
|
|
|
self._client.redraw()
|
|
|
|
def save_changes_delayed(self):
|
|
if not self._save_thread:
|
|
def threadf():
|
|
self.save_changes()
|
|
self._save_thread = None
|
|
self._save_thread = threading.Timer(.25, threadf)
|
|
self._save_thread.start()
|
|
|
|
def save_changes(self):
|
|
changes = self.commit_changes()
|
|
changes = [chunk for chunk in changes if not chunk[1].empty()]
|
|
|
|
if changes:
|
|
self._client.send_changes(changes)
|
|
|
|
def load(self, pos):
|
|
raise Exception
|
|
|
|
def load_list(self, coords):
|
|
coords = [pos for pos in coords if pos not in self._chunks]
|
|
if coords:
|
|
self._client.request_chunks(coords)
|
|
|
|
def unload_list(self, coords):
|
|
if coords:
|
|
#self.save_changes()
|
|
self._client.unload_chunks(coords)
|
|
super().unload_list(coords)
|