def METHOD_NAME(self, case, seq):
    assert self._started, "Not started!"
    send = self.send
    for instruction, arg in instructions(case["description"]):
        if instruction == "crash":
            raise Crash()
        elif instruction == "sleep":
            time.sleep(float(arg))
        elif instruction == "hang":
            self._hang_on_stop = True
        elif instruction == "error":
            result = dict(
                errored=True,
                seq=seq,
                context=dict(kv.split("=", 1) for kv in arg.split(",")),
            )
            return self.send(**result)
        elif instruction == "skip":
            result = dict(
                (each.split("=", 1) for each in arg.split(",")),
                skipped=True,
                seq=seq,
            )
            return self.send(**result)
        elif instruction == "split":
            def send(**response):
                dumped = json.dumps(response)
                size = len(dumped) // 2
                self._stdout.write(dumped[:size])
                self._stdout.flush()
                time.sleep(0.1)
                self._stdout.write(dumped[size:])
                self._stdout.flush()
                time.sleep(0.1)
                self._stdout.write("\n")
                self._stdout.flush()
    results = {"results": []}
    for test in case["tests"]:
        result = {"valid": False}
        for instruction, arg in instructions(test["description"]):
            if instruction == "crash":
                raise Crash()
            elif instruction == "sleep":
                time.sleep(float(arg))
            if instruction == "valid":
                result = _VALID.get(arg, {"valid": arg})
            elif instruction == "skip":
                result = dict(
                    each.split("=", 1) for each in arg.split(",")
                )
                result.update(skipped=True)
            elif instruction == "error":
                result = dict(
                    errored=True,
                    context=dict(
                        kv.split("=", 1) for kv in arg.split(",")
                    ),
                )
        results["results"].append(result)
    send(seq=seq, **results)