async def METHOD_NAME(
    self,
    forward_calls: List["DendriteForwardCall"],
    rewards: Union[List[float], torch.FloatTensor],
    timeout: float = 12.0,
):
    rewards = rewards if not isinstance(rewards, torch.Tensor) else rewards.tolist()
    async def query():
        coroutines = [
            forward_calls.METHOD_NAME(reward)
            for call, reward in list(zip(forward_calls, rewards))
        ]
        all_responses = await asyncio.gather(*coroutines)
        return all_responses
    await query()