# @generated by generate_proto_mypy_stubs.py.  Do not edit!
import sys
from abc import (
    ABCMeta as abc___ABCMeta,
    abstractmethod as abc___abstractmethod,
)

from concurrent.futures import (
    Future as concurrent___futures___Future,
)

from google.protobuf.descriptor import (
    Descriptor as google___protobuf___descriptor___Descriptor,
    FileDescriptor as google___protobuf___descriptor___FileDescriptor,
)

from google.protobuf.message import (
    Message as google___protobuf___message___Message,
)

from google.protobuf.service import (
    RpcChannel as google___protobuf___service___RpcChannel,
    RpcController as google___protobuf___service___RpcController,
    Service as google___protobuf___service___Service,
)

from steammessages_unified_base_pb2 import (
    NoResponse as steammessages_unified_base_pb2___NoResponse,
)

from typing import (
    Callable as typing___Callable,
    Optional as typing___Optional,
    Text as typing___Text,
)

from typing_extensions import (
    Literal as typing_extensions___Literal,
)


builtin___bool = bool
builtin___bytes = bytes
builtin___float = float
builtin___int = int


DESCRIPTOR: google___protobuf___descriptor___FileDescriptor = ...

class CDataPublisher_ClientContentCorruptionReport_Notification(google___protobuf___message___Message):
    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
    appid: builtin___int = ...
    depotid: builtin___int = ...
    download_source: typing___Text = ...
    objectid: typing___Text = ...
    cellid: builtin___int = ...
    is_manifest: builtin___bool = ...
    object_size: builtin___int = ...
    corruption_type: builtin___int = ...
    used_https: builtin___bool = ...
    oc_proxy_detected: builtin___bool = ...

    def __init__(self,
        *,
        appid : typing___Optional[builtin___int] = None,
        depotid : typing___Optional[builtin___int] = None,
        download_source : typing___Optional[typing___Text] = None,
        objectid : typing___Optional[typing___Text] = None,
        cellid : typing___Optional[builtin___int] = None,
        is_manifest : typing___Optional[builtin___bool] = None,
        object_size : typing___Optional[builtin___int] = None,
        corruption_type : typing___Optional[builtin___int] = None,
        used_https : typing___Optional[builtin___bool] = None,
        oc_proxy_detected : typing___Optional[builtin___bool] = None,
        ) -> None: ...
    def HasField(self, field_name: typing_extensions___Literal[u"appid",b"appid",u"cellid",b"cellid",u"corruption_type",b"corruption_type",u"depotid",b"depotid",u"download_source",b"download_source",u"is_manifest",b"is_manifest",u"object_size",b"object_size",u"objectid",b"objectid",u"oc_proxy_detected",b"oc_proxy_detected",u"used_https",b"used_https"]) -> builtin___bool: ...
    def ClearField(self, field_name: typing_extensions___Literal[u"appid",b"appid",u"cellid",b"cellid",u"corruption_type",b"corruption_type",u"depotid",b"depotid",u"download_source",b"download_source",u"is_manifest",b"is_manifest",u"object_size",b"object_size",u"objectid",b"objectid",u"oc_proxy_detected",b"oc_proxy_detected",u"used_https",b"used_https"]) -> None: ...
type___CDataPublisher_ClientContentCorruptionReport_Notification = CDataPublisher_ClientContentCorruptionReport_Notification

class CValveHWSurvey_GetSurveySchedule_Request(google___protobuf___message___Message):
    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
    surveydatetoken: typing___Text = ...
    surveydatetokenversion: builtin___int = ...

    def __init__(self,
        *,
        surveydatetoken : typing___Optional[typing___Text] = None,
        surveydatetokenversion : typing___Optional[builtin___int] = None,
        ) -> None: ...
    def HasField(self, field_name: typing_extensions___Literal[u"surveydatetoken",b"surveydatetoken",u"surveydatetokenversion",b"surveydatetokenversion"]) -> builtin___bool: ...
    def ClearField(self, field_name: typing_extensions___Literal[u"surveydatetoken",b"surveydatetoken",u"surveydatetokenversion",b"surveydatetokenversion"]) -> None: ...
type___CValveHWSurvey_GetSurveySchedule_Request = CValveHWSurvey_GetSurveySchedule_Request

class CValveHWSurvey_GetSurveySchedule_Response(google___protobuf___message___Message):
    DESCRIPTOR: google___protobuf___descriptor___Descriptor = ...
    surveydatetoken: builtin___int = ...
    surveydatetokenversion: builtin___int = ...

    def __init__(self,
        *,
        surveydatetoken : typing___Optional[builtin___int] = None,
        surveydatetokenversion : typing___Optional[builtin___int] = None,
        ) -> None: ...
    def HasField(self, field_name: typing_extensions___Literal[u"surveydatetoken",b"surveydatetoken",u"surveydatetokenversion",b"surveydatetokenversion"]) -> builtin___bool: ...
    def ClearField(self, field_name: typing_extensions___Literal[u"surveydatetoken",b"surveydatetoken",u"surveydatetokenversion",b"surveydatetokenversion"]) -> None: ...
type___CValveHWSurvey_GetSurveySchedule_Response = CValveHWSurvey_GetSurveySchedule_Response

class DataPublisher(google___protobuf___service___Service, metaclass=abc___ABCMeta):
    @abc___abstractmethod
    def ClientContentCorruptionReport(self,
        rpc_controller: google___protobuf___service___RpcController,
        request: type___CDataPublisher_ClientContentCorruptionReport_Notification,
        done: typing___Optional[typing___Callable[[steammessages_unified_base_pb2___NoResponse], None]],
    ) -> concurrent___futures___Future[steammessages_unified_base_pb2___NoResponse]: ...
class DataPublisher_Stub(DataPublisher):
    def __init__(self, rpc_channel: google___protobuf___service___RpcChannel) -> None: ...
    def ClientContentCorruptionReport(self,
        rpc_controller: google___protobuf___service___RpcController,
        request: type___CDataPublisher_ClientContentCorruptionReport_Notification,
        done: typing___Optional[typing___Callable[[steammessages_unified_base_pb2___NoResponse], None]],
    ) -> concurrent___futures___Future[steammessages_unified_base_pb2___NoResponse]: ...
class ValveHWSurvey(google___protobuf___service___Service, metaclass=abc___ABCMeta):
    @abc___abstractmethod
    def GetSurveySchedule(self,
        rpc_controller: google___protobuf___service___RpcController,
        request: type___CValveHWSurvey_GetSurveySchedule_Request,
        done: typing___Optional[typing___Callable[[type___CValveHWSurvey_GetSurveySchedule_Response], None]],
    ) -> concurrent___futures___Future[type___CValveHWSurvey_GetSurveySchedule_Response]: ...
class ValveHWSurvey_Stub(ValveHWSurvey):
    def __init__(self, rpc_channel: google___protobuf___service___RpcChannel) -> None: ...
    def GetSurveySchedule(self,
        rpc_controller: google___protobuf___service___RpcController,
        request: type___CValveHWSurvey_GetSurveySchedule_Request,
        done: typing___Optional[typing___Callable[[type___CValveHWSurvey_GetSurveySchedule_Response], None]],
    ) -> concurrent___futures___Future[type___CValveHWSurvey_GetSurveySchedule_Response]: ...