Stop server in background thread

from dataclasses import dataclass, field

from pathlib import Path

from socketserver import BaseServer, StreamRequestHandler, ThreadingUnixStreamServer

from threading import Thread

from poolpay.wire.Message import Message

        self._server.serve_forever()

    def stop(self) -> None:

        # Shutdown must be run in another thread (per documentation), otherwise you get a deadlock

        def _stop() -> None:

            self._server.shutdown()

            self._server.server_close()

            self.socket_path.unlink()

        Thread(target=_stop).start()