# Path: kuyruk/exceptions.py
# class ResultTimeout(KuyrukError):
#     """
#     Raised from :func:`kuyruk.Task.send_to_queue` if ``wait_result`` is set and
#     reply is not received in ``wait_result`` seconds.
# 
#     """
#     pass
# 
# class RemoteException(KuyrukError):
#     """
#     Raised from :func:`kuyruk.Task.send_to_queue` if ``wait_result`` is set and
#     exception is raised on the worker while running the task.
# 
#     """
#     def __init__(self, type_: Type, value: Exception, traceback: TracebackType) -> None:
#         self.type = type_
#         self.value = value
#         self.traceback = traceback
# 
#     def __str__(self) -> str:
#         return "%s(%r)" % (self.type, self.value)


import json
import socket
import logging
import amqp
from time import monotonic
from typing import Union
from kuyruk.exceptions import ResultTimeout, RemoteException



logger = logging.getLogger(__name__)


class Result:

    def __init__(self, connection: amqp.Connection) -> None:

# Path: kuyruk/exceptions.py
# class ResultTimeout(KuyrukError):
#     """
#     Raised from :func:`kuyruk.Task.send_to_queue` if ``wait_result`` is set and
#     reply is not received in ``wait_result`` seconds.
# 
#     """
#     pass
# 
# class RemoteException(KuyrukError):
#     """
#     Raised from :func:`kuyruk.Task.send_to_queue` if ``wait_result`` is set and
#     exception is raised on the worker while running the task.
# 
#     """
#     def __init__(self, type_: Type, value: Exception, traceback: TracebackType) -> None:
#         self.type = type_
#         self.value = value
#         self.traceback = traceback
# 
#     def __str__(self) -> str:
#         return "%s(%r)" % (self.type, self.value)


# Path: kuyruk/result.py
import json
import socket
import logging
import amqp
from time import monotonic
from typing import Union
from kuyruk.exceptions import ResultTimeout, RemoteException




logger = logging.getLogger(__name__)


class Result:

    def __init__(self, connection: amqp.Connection) -> None:

        self._connection = connection