package Ġcourse . kotlin . web flux demo . web Ċ Ċ import Ġcourse . kotlin . web flux demo . domain . Quotes Generator Flow Ċ import Ġcourse . kotlin . web flux demo . model . Quote Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġkotlinx . coroutines . flow . emit All Ċ import Ġkotlinx . coroutines . flow . onStart Ċ import Ġorg . springframework . messaging . handler . annotation . Message Mapping Ċ import Ġorg . springframework . messaging . handler . annotation . Payload Ċ import Ġorg . springframework . stereotype . Controller Ċ import Ġjava . time . Duration Ċ Ċ @ Controller Ċ @ Message Mapping (" quotes ") Ċ class ĠQu otes R Socket Ġ( val Ġgenerator : ĠQu otes Generator Flow ) Ġ{ Ċ Ċ // ĠĠĠ Ġ@ Message Mapping (" stream ") Ċ // ĠĠĠ Ġsuspend Ġfun Ġreceive (@ Payload Ġinbound Messages : ĠFlow < Message VM >) Ġ= Ċ // ĠĠĠĠĠĠĠ Ġmessage Service . post ( inbound Messages ) ĊĊĠĠĠ Ġ@ Message Mapping (" stream ") ĊĠĠĠ Ġfun Ġsend (): ĠFlow < Quote > Ġ= Ġgenerator ĊĠĠĠĠĠĠĠ Ġ. get Quotes Stream ( Duration . of Millis ( 2 5 0 )) Ċ // ĠĠĠĠĠĠĠ Ġ. onStart Ġ{ Ċ // ĠĠĠĠĠĠĠĠĠĠĠ Ġemit All ( message Service . latest ()) Ċ // ĠĠĠĠĠĠĠ Ġ} Ċ } Ċ