import lombok.RequiredArgsConstructor;
import org.springframework.http.codec.ServerSentEvent;
import org.springframework.web.bind.annotation.*;
import lombok.RequiredArgsConstructor;
import org.springframework.http.codec.ServerSentEvent;
import org.springframework.web.bind.annotation.*;
.createChatRoom(chatRoomId, name)
.map(ChatRoomInfoTo::from);
}
.createChatRoom(chatRoomId, name)
.map(ChatRoomInfoTo::from);
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> put(chatRoomData, username, messageId, text));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> put(chatRoomData, username, messageId, text));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> get(chatRoomData, username, messageId));
}
.getChatRoomData(chatRoomId)
.flatMap(chatRoomData -> get(chatRoomData, username, messageId));
}
@GetMapping(path = "{chatRoomId}/listen")
public Flux<ServerSentEvent<MessageTo>> listen(@PathVariable UUID chatRoomId)
{
@GetMapping(path = "{chatRoomId}/listen")
public Flux<ServerSentEvent<MessageTo>> listen(@PathVariable UUID chatRoomId)
{