@apiproxy_stub.Synchronized
  def connect_channel(self, token):
    client_id = self.validate_token_and_extract_client_id(token)



    if client_id in self._connected_channel_messages:
      timeout = self._time_func() + ChannelServiceStub.CHANNEL_TIMEOUT_SECONDS

      self.request_data.get_dispatcher().update_event(
          timeout, 'channel-disconnect', client_id)
      return



    self._connected_channel_messages[client_id] = []
    self.add_connect_event(client_id)
    self.add_disconnect_event(client_id)
Marks the channel identified by the token (token) as connected.
dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/api/channel/channel_service_stub.py/ChannelServiceStub.connect_channel