Edit

StreamingRequestHandler Class

Constructor

StreamingRequestHandler(bot: Bot, activity_processor: StreamingActivityProcessor, web_socket: WebSocket, logger: Logger = None)

Parameters

Name Description
bot
Required
activity_processor
Required
web_socket
Required
logger
Default value: None

Methods

conversation_added_time
forget_conversation
has_conversation
listen
process_request
send_activity
send_streaming_request

conversation_added_time

conversation_added_time(conversation_id: str) -> datetime

Parameters

Name Description
conversation_id
Required

forget_conversation

forget_conversation(conversation_id: str)

Parameters

Name Description
conversation_id
Required

has_conversation

has_conversation(conversation_id: str) -> bool

Parameters

Name Description
conversation_id
Required

listen

async listen()

process_request

async process_request(request: ReceiveRequest, logger: Logger, context: object) -> StreamingResponse

Parameters

Name Description
request
Required
logger
Required
context
Required

send_activity

async send_activity(activity: Activity) -> ResourceResponse

Parameters

Name Description
activity
Required

send_streaming_request

async send_streaming_request(request: StreamingRequest) -> ReceiveResponse

Parameters

Name Description
request
Required

Attributes

service_url