INNER CODE UNIT · Python

get_chat_history

leonh/redis-streams-fastapi-chat · chat.py:114

async def get_chat_history():
    pass


async def ws_send_moderator(websocket: WebSocket, chat_info: dict):
    """
    wait for new items on chat stream and
    send data from server to client over a WebSocket

    :param websocket:
    :type websocket:
    :param chat_info:
    :type chat_info:
    """
    pool = await get_redis_pool()
    streams = chat_info['room'].split(',')
    latest_ids = {stream: '$' for stream in streams}
    ws_connected = True

View source record →