Avoid threading (which makes stuff non-deterministic and me sad)

from collections.abc import Callable

from dataclasses import dataclass, field

from pathlib import Path

from socketserver import BaseServer, StreamRequestHandler, ThreadingUnixStreamServer

from socketserver import BaseServer, StreamRequestHandler, UnixStreamServer

from threading import Thread

from poolpay.wire.Packet import Packet

        # terminated run of the application. We could of course also just have crashed a still running run of

        # the application (if we started the server on the same socket twice), but this is very unlikely.

        self.socket_path.unlink(missing_ok=True)

        self._server = ThreadingUnixStreamServer(

        self._server = UnixStreamServer(

            str(self.socket_path.resolve()),

            Server.RequestHandler,

            bind_and_activate=False,