def test_notification_enqueued(self):
    input_stream = io.BytesIO()
    output_stream = io.BytesIO()
    test_client = JSONRPCServer(input_stream, output_stream)
    test_client.send_notification('test/test', {'test': 'test'})
    request = test_client._output_queue.get()
    self.assertEqual(request.message_method, 'test/test')
    self.assertDictEqual(request.message_params, {'test': 'test'})
def test_notification_enqueued(self):
    input_stream = io.BytesIO()
    output_stream = io.BytesIO()
    test_client = JSONRPCServer(input_stream, output_stream)
    test_client.send_notification('test/test', {'test': 'test'})
    request = test_client._output_queue.get()
    self.assertEqual(request.message_method, 'test/test')
    self.assertDictEqual(request.message_params, {'test': 'test'})