def METHOD_NAME(self):
    def call_soon_threadsafe(func, arg, fut=None):
        if fut:
            res = func(arg, fut)
        else:
            res = func(arg)
        return res
    self._loop = MagicMock()
    self._loop.call_soon_threadsafe = MagicMock(side_effect=call_soon_threadsafe)
    self._gy_app = MagicMock()
    self._enforcer_app = MagicMock()
    self._enforcement_stats = MagicMock()
    self._dpi_app = MagicMock()
    self._ue_mac_app = MagicMock()
    self._check_quota_app = MagicMock()
    self._ipfix_app = MagicMock()
    self._vlan_learn_app = MagicMock()
    self._tunnel_learn_app = MagicMock()
    self._classifier_app = MagicMock()
    self._ingress_app = MagicMock()
    self._middle_app = MagicMock()
    self._egress_app = MagicMock()
    self._ng_servicer_app = MagicMock()
    self._service_config = MagicMock()
    self._service_manager = MagicMock()
    self._service_manager.is_app_enabled.side_effect = lambda x: True
    for controller in [
        self._gy_app, self._enforcer_app,
        self._enforcement_stats,
    ]:
        controller.check_setup_request_epoch.side_effect = lambda x: None
        controller.is_controller_ready = lambda: True
    self.pipelined_srv = PipelinedRpcServicer(
        self._loop,
        self._gy_app,
        self._enforcer_app,
        self._enforcement_stats,
        self._dpi_app,
        self._ue_mac_app,
        self._check_quota_app,
        self._ipfix_app,
        self._vlan_learn_app,
        self._tunnel_learn_app,
        self._classifier_app,
        self._ingress_app,
        self._middle_app,
        self._egress_app,
        self._ng_servicer_app,
        self._service_config,
        self._service_manager,
    )