mirror of
https://github.com/yzernik/squeaknode.git
synced 2026-08-14 12:43:24 +02:00
22 lines
471 B
Python
22 lines
471 B
Python
import logging
|
|
import threading
|
|
|
|
from squeaknode.network.peer_client import PeerClient
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class PeerConnection:
|
|
def __init__(self, peer):
|
|
self.peer = peer
|
|
self.peer_client = PeerClient(
|
|
self.peer.host,
|
|
self.peer.port,
|
|
)
|
|
self._stop_event = threading.Event()
|
|
|
|
def stop(self):
|
|
self._stop_event.set()
|
|
|
|
def stopped(self):
|
|
return self._stop_event.is_set()
|