File tree Expand file tree Collapse file tree 2 files changed +2
-7
lines changed
src/main/kotlin/com/example/kotlin/chat/controller Expand file tree Collapse file tree 2 files changed +2
-7
lines changed Original file line number Diff line number Diff line change 11package com.example.kotlin.chat.controller
22
3- import com.example.kotlin.chat.service.MessageService
4- import com.example.kotlin.chat.service.MessageVM
5- import kotlinx.coroutines.flow.toList
63import org.springframework.stereotype.Controller
7- import org.springframework.ui.Model
8- import org.springframework.ui.set
94import org.springframework.web.bind.annotation.GetMapping
105
116@Controller
Original file line number Diff line number Diff line change @@ -14,11 +14,11 @@ import org.springframework.stereotype.Controller
1414class MessageResource (val messageService : MessageService ) {
1515
1616 @MessageMapping(" stream" )
17- suspend fun receiveStream (@Payload inboundMessages : Flow <MessageVM >) =
17+ suspend fun receive (@Payload inboundMessages : Flow <MessageVM >) =
1818 messageService.post(inboundMessages)
1919
2020 @MessageMapping(" stream" )
21- suspend fun sendStream (): Flow <MessageVM > = messageService
21+ suspend fun send (): Flow <MessageVM > = messageService
2222 .stream()
2323 .onStart {
2424 emitAll(messageService.latest())
You can’t perform that action at this time.
0 commit comments