私の消費者に非同期

Question

応答を送信するためにDjangoのチャネルcomsumerを作る方法を、私はいくつかのreply_channel.sendを書く

> def ws_message(message):  
>  line = get_output() 
>  message.reply_channel.send({ 
>   "text": line, 
>  }) 
>  line = get_output() 
>  message.reply_channel.send({ 
>   "text": line, 
>  }) line = get_output() 
>  message.reply_channel.send({ 
>   "text": line, 
>  }) 

そして私は、消費者が最後message.reply_channel.sendまで、これらの3つの応答を送信していないことがわかりました実行される。

reply_channel.sendが実行されるたびにすぐに返信を送信できるようにするにはどうすればよいですか？

ランダムな間隔で出力を生成するプログラムがあるため、これを行いました。上記のコードを使用すると、Webページは完全な結果が到着するまで待機し、ユーザーにとっては非常に不愉快です。

ありがとうございます！

Answer 1

pass immediate = send引数に真。