From 83cbaf112729bc9410bdcc2196802120a3217783 Mon Sep 17 00:00:00 2001 From: Jusong Yu Date: Sat, 18 Jan 2025 01:58:40 +0100 Subject: [PATCH] misc --- tests/test_communications.py | 76 ------------------------------------ 1 file changed, 76 deletions(-) delete mode 100644 tests/test_communications.py diff --git a/tests/test_communications.py b/tests/test_communications.py deleted file mode 100644 index f7e04255..00000000 --- a/tests/test_communications.py +++ /dev/null @@ -1,76 +0,0 @@ -# -*- coding: utf-8 -*- -"""Tests for the :mod:`plumpy.communications` module.""" - -import pytest -from kiwipy import CommunicatorHelper - -from plumpy.communications import LoopCommunicator - - -class Subscriber: - """Test class that mocks a subscriber.""" - - def __call__(self): - pass - - -class Communicator(CommunicatorHelper): - def task_send(self, task, no_reply=False): - pass - - def rpc_send(self, recipient_id, msg): - pass - - def broadcast_send(self, body, sender=None, subject=None, correlation_id=None): - pass - - -@pytest.fixture -def loop_communicator(): - """Return an instance of `LoopCommunicator`.""" - return LoopCommunicator(Communicator()) - - -@pytest.fixture -def subscriber(): - """Return an instance of `Subscriber`.""" - return Subscriber() - - -def test_add_rpc_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.add_rpc_subscriber` method.""" - assert loop_communicator.add_rpc_subscriber(subscriber) is not None - - identifier = 'identifier' - assert loop_communicator.add_rpc_subscriber(subscriber, identifier) == identifier - - -def test_remove_rpc_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.remove_rpc_subscriber` method.""" - identifier = loop_communicator.add_rpc_subscriber(subscriber) - loop_communicator.remove_rpc_subscriber(identifier) - - -def test_add_broadcast_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.add_broadcast_subscriber` method.""" - assert loop_communicator.add_broadcast_subscriber(subscriber) is not None - - identifier = 'identifier' - assert loop_communicator.add_broadcast_subscriber(subscriber, identifier) == identifier - - -def test_remove_broadcast_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.remove_broadcast_subscriber` method.""" - identifier = loop_communicator.add_broadcast_subscriber(subscriber) - loop_communicator.remove_broadcast_subscriber(identifier) - - -def test_add_task_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.add_task_subscriber` method.""" - assert loop_communicator.add_task_subscriber(subscriber) is not None - - -def test_remove_task_subscriber(loop_communicator, subscriber): - """Test the `LoopCommunicator.remove_task_subscriber` method.""" - identifier = loop_communicator.add_task_subscriber(subscriber) - loop_communicator.remove_task_subscriber(identifier)