def test_server_init(self):
    input_stream = io.BytesIO()
    output_stream = io.BytesIO()
    logger = utils.get_mock_logger()
    server = JSONRPCServer(input_stream, output_stream, logger=logger)
    self.assertIsInstance(server.writer, JSONRPCWriter)
    self.assertIsInstance(server.reader, JSONRPCReader)
    self.assertIs(server._logger, logger)
    self.assertEqual(server._version, '0')
    self.assertFalse(server._stop_requested)
    self.assertIsInstance(server._output_queue, Queue)
    self.assertTrue(server._output_queue.all_tasks_done)
    self.assertDictEqual(server._notification_handlers, {})
    self.assertListEqual(server._shutdown_handlers, [])
    self.assertIsNone(server._output_consumer)
    self.assertIsNone(server._input_consumer)
    self.assertTrue(('echo' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['echo'])
    self.assertTrue(('version' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['version'].handler)
    self.assertTrue(('shutdown' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['shutdown'].handler)
    self.assertTrue(('exit' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['exit'].handler)
def test_server_init(self):
    input_stream = io.BytesIO()
    output_stream = io.BytesIO()
    logger = utils.get_mock_logger()
    server = JSONRPCServer(input_stream, output_stream, logger=logger)
    self.assertIsInstance(server.writer, JSONRPCWriter)
    self.assertIsInstance(server.reader, JSONRPCReader)
    self.assertIs(server._logger, logger)
    self.assertEqual(server._version, '0')
    self.assertFalse(server._stop_requested)
    self.assertIsInstance(server._output_queue, Queue)
    self.assertTrue(server._output_queue.all_tasks_done)
    self.assertDictEqual(server._notification_handlers, {})
    self.assertListEqual(server._shutdown_handlers, [])
    self.assertIsNone(server._output_consumer)
    self.assertIsNone(server._input_consumer)
    self.assertTrue(('echo' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['echo'])
    self.assertTrue(('version' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['version'].handler)
    self.assertTrue(('shutdown' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['shutdown'].handler)
    self.assertTrue(('exit' in server._request_handlers))
    self.assertIsNotNone(server._request_handlers['exit'].handler)