0j dZddlZddlmZmZmZmZmZmZddl m Z m Z m Z edZ GddejZGdd eZdS) z[ Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT License. N) AwaitableCallableLiteralOptionalProtocolUnion)MessageActivityInput SentActivityTypingActivityInput)chunkcloseceZdZdZdS)StreamCancelledErrorzPRaised when a stream operation is attempted after the stream has been cancelled.N)__name__ __module__ __qualname____doc__m/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/microsoft_teams/apps/plugins/streamer.pyrrsZZDrrc0eZdZdZedefdZedefdZedefdZ edefdZ de e ge dfddfd Zde e ge dfddfd Zd eeeefddfd Zd eddfdZddZdee fdZdS)StreamerProtocolz7Component that can send streamed chunks of an activity.returncdS)z Whether the stream has been canceled. For example when the user pressed the Stop button or the 2-minute timeout has exceeded. Nrselfs rcanceledzStreamerProtocol.canceleds rcdS)z/Whether the final stream message has been sent.Nrrs rclosedzStreamerProtocol.closed  rcdS)z-The total number of chunks queued to be sent.Nrrs rcountzStreamerProtocol.count$r rcdS)z The sequence number, representing the number of stream activities sent. Several chunks can be aggregated into one stream activity due to differences in Api rate limits. Nrrs rsequencezStreamerProtocol.sequence)s  rhandlerNcdS)z Register a handler for chunk events. Args: handler: Async function that will be called for each chunk activity Nrrr%s ron_chunkzStreamerProtocol.on_chunk3  rcdS)z Register a handler for close events. Args: handler: Async function that will be called when the stream closes Nrr's ron_closezStreamerProtocol.on_close<r)ractivitycdS)z) Emit an activity chunk. Nr)rr,s remitzStreamerProtocol.emitE  rtextcdS)z Send status updates before emitting (ex. "Thinking..."). Args: text: The status text to send. Nr)rr0s rupdatezStreamerProtocol.updateKr)rcdS)zY Discard any text accumulated so far so the final activity is card-only. Nrrs r clear_textzStreamerProtocol.clear_textTr/rc KdS)z# Close the stream. Nrrs rr zStreamerProtocol.closeZs  r)rN)rrrrpropertyboolrrintr"r$rr rr(r+rr r strr.r2r4rr rrrrrsAA  $   X     X  s   X  #   X  ,4)H I d     ,4)H I d     U#79Lc#QR W[     3 4         Xl3      rr)rasynciotypingrrrrrrmicrosoft_teams.apir r r StreamerEventCancelledErrorrrrrrr?s JJJJJJJJJJJJJJJJWWWWWWWWWW()      71   J J J J J xJ J J J J r