def __init__(self,  # pylint: disable=R0913
                 remote_addr,
                 remote_addr_family=socket.AF_INET,
                 remote_socket_type=socket.SOCK_STREAM,
                 server_addr=("127.0.0.1", 0),
                 server_addr_family=socket.AF_INET,
                 server_socket_type=socket.SOCK_STREAM,
                 local_linger_args=None):
        self._logger = logging.getLogger(__name__)

        self._remote_addr = remote_addr
        self._remote_addr_family = remote_addr_family
        assert remote_socket_type == socket.SOCK_STREAM, remote_socket_type
        self._remote_socket_type = remote_socket_type


        assert server_addr is not None
        self._server_addr = server_addr

        assert server_addr_family is not None
        self._server_addr_family = server_addr_family

        assert server_socket_type == socket.SOCK_STREAM, server_socket_type
        self._server_socket_type = server_socket_type

        self._local_linger_args = local_linger_args

        self._subproc = None
Given a pytree, splice the continuation marker into nodes.
dataset/ETHPy150Open pika/pika/tests/acceptance/forward_server.py/ForwardServer.__init__--crossover with--dataset/ETHPy150Open google/yapf/yapf/yapflib/continuation_splicer.py/SpliceContinuations