def METHOD_NAME() -> None:
    """Test full workflow."""
    # Prepare
    rounds = 5
    client_messages_received: List[ClientMessage] = []
    bridge = GrpcBridge()
    ins_wrapper_iterator = bridge.ins_wrapper_iterator()
    worker_thread = start_worker(rounds, bridge, client_messages_received)
    # Execute
    # Simulate remote client side
    for _ in range(rounds):
        try:
            _ = next(ins_wrapper_iterator)
            bridge.set_res_wrapper(ResWrapper(client_message=ClientMessage()))
        except Exception as exception:
            raise Exception from exception
    # Wait until worker_thread is finished
    worker_thread.join(timeout=1)
    # Assert
    assert len(client_messages_received) == rounds