Package com.arms.api.chat.service

Class ChatServiceImpl

java.lang.Object
com.arms.api.chat.service.ChatServiceImpl
All Implemented Interfaces:
UserQueryService<ChatDTO>
@Service public class ChatServiceImpl extends Object implements UserQueryService<ChatDTO>

  • Constructor Details

    • ChatServiceImpl

      public ChatServiceImpl()

  • Method Details

    • stream

      public reactor.core.publisher.Flux<String> stream(ChatDTO query)
      Description copied from interface: UserQueryService
      질의를 AI 파이프라인에 전달하고 응답을 실시간 스트림으로 반환합니다.
      Specified by:
      stream in interface UserQueryService<ChatDTO>
      Parameters:
      query - 사용자 질의 객체
      Returns:
      토큰 단위 스트리밍 응답

    • generate

      public reactor.core.publisher.Mono<String> generate(ChatDTO query)
      Description copied from interface: UserQueryService
      질의를 AI 파이프라인에 전달하고 완성된 응답을 단건으로 반환합니다.
      Specified by:
      generate in interface UserQueryService<ChatDTO>
      Parameters:
      query - 사용자 질의 객체
      Returns:
      완성된 응답 문자열

    • stopStream

      public String stopStream(String sessionId)
      Description copied from interface: UserQueryService
      진행 중인 스트림을 sessionId 기준으로 중단합니다.
      Specified by:
      stopStream in interface UserQueryService<ChatDTO>
      Parameters:
      sessionId - 중단할 스트림의 세션 ID
      Returns:
      처리 결과 메시지

    • buildContext

      public reactor.core.publisher.Mono<PromptContextVO> buildContext(ChatDTO query)

    • executeStream

      public reactor.core.publisher.Flux<String> executeStream(ChatDTO query)