async def send_to_all(self, messages: List[Message], node_type: NodeType):
    for (_, connection) in self.all_connections.items():
        if (connection.connection_type is node_type):
            for message in messages:
                (await connection.send_message(message))
async def send_to_all(self, messages: List[Message], node_type: NodeType):
    for (_, connection) in self.all_connections.items():
        if (connection.connection_type is node_type):
            for message in messages:
                (await connection.send_message(message))