def METHOD_NAME(self, task, timeout=MAXIMUM_JOIN_TIME):
    """
    Beta method to stream response from smee.io
    """
    response = self.session.head(
        "https://smee.io/new", timeout=self.response_timeout
    )
    smee_url = response.headers["Location"]
    task = task.serialize()
    request = {
        "clientKey": self.client_key,
        "task": task,
        "softId": self.SOFT_ID,
        "languagePool": self.language_pool,
        "callbackUrl": smee_url,
    }
    r = self.session.get(
        url=smee_url,
        headers={"Accept": "text/event-stream"},
        stream=True,
        timeout=(self.response_timeout, timeout),
    )
    response = self.session.post(
        url=urljoin(self.base_url, self.CREATE_TASK_URL),
        json=request,
        timeout=self.response_timeout,
    ).json()
    self._check_response(response)
    for line in r.iter_lines():
        content = line.decode("utf-8")
        if '"host":"smee.io"' not in content:
            continue
        payload = json.loads(split(content, ":", 1)[1].strip())
        if "taskId" not in payload["body"] or str(payload["body"]["taskId"]) != str(
            response["taskId"]
        ):
            continue
        r.close()
        if task["type"] == "CustomCaptchaTask":
            payload["body"]["solution"] = payload["body"]["data"][0]
        job = Job(client=self, task_id=response["taskId"])
        job._last_result = payload["body"]
        return job