code: async def update_watermark(self, update_watermark_request):
          
          response = hangouts_pb2.UpdateWatermarkResponse()
          await self._pb_request('conversations/updatewatermark',
                                 update_watermark_request, response)
          return response
docs: Update the watermark (read timestamp) of a conversation.