async def peek(self, count=<NUM_LIT:1>, start_from=<NUM_LIT:0>, session=None, **kwargs):
message = {<EOL>'<STR_LIT>': types.AMQPLong(start_from),<EOL>'<STR_LIT>': int(count)}<EOL>if self.entity and self.requires_session:<EOL><INDENT>if not session:<EOL><INDENT>raise ValueError("<STR_LIT>")<EOL><DEDENT>message['<STR_LIT>'] = session<EOL><DEDENT>async with BaseHandler(<EOL>self.entity_uri, self.auth_config, loop=self.loop, debug=self.debug, **kwargs) as handler:<EOL><INDENT>return await handler._mgmt_request_response(  <EOL>REQUEST_RESPONSE_PEEK_OPERATION,<EOL>message,<EOL>mgmt_handlers.peek_op)<EOL><DEDENT>
Browse messages currently pending in the queue.

        Peeked messages are not removed from queue, nor are they locked. They cannot be completed,
        deferred or dead-lettered.

        :param count: The maximum number of messages to try and peek. The default
         value is 1.
        :type count: int
        :param start_from: A message sequence number from which to start browsing messages.
        :type start_from: int
        :param session: If the entity requires sessions, a session ID must be supplied
         in order that only messages from that session will be browsed. If the entity
         does not require sessions this value will be ignored.
        :type session: str
        :rtype: list[~azure.servicebus.common.message.PeekMessage]

        Example:
            .. literalinclude:: ../examples/async_examples/test_examples_async.py
                :start-after: [START client_peek_messages]
                :end-before: [END client_peek_messages]
                :language: python
                :dedent: 4
                :caption: Peek messages in the queue.