UFC - Unified Finance Client/com.ulalax.ufc.infrastructure.yahoo.streaming/StreamingClient

StreamingClient

class StreamingClient : AutoCloseable(source)

Yahoo Finance WebSocket Streaming 클라이언트.

WebSocket을 통해 실시간 주식 시세 데이터를 수신합니다. 자동 재연결, 하트비트, 구독 관리 기능을 제공합니다.

사용 예시:

val client = StreamingClient.create()
client.connect()

// 데이터 수신
client.prices.collect { price ->
    println("${price.symbol}: ${price.price}")
}

// 구독
client.subscribe("AAPL")
client.subscribe(listOf("GOOGL", "MSFT"))

// 정리
client.close()

Types

object Companion

Properties

val events: SharedFlow<StreamingEvent>

연결 상태 이벤트 스트림.

val prices: SharedFlow<StreamingPrice>

실시간 가격 데이터 스트림.

val quotes: SharedFlow<StreamingQuote>

실시간 상세 시세 데이터 스트림.

Functions

open override fun close()

리소스를 정리하고 연결을 종료합니다.

suspend fun connect()

WebSocket 연결을 수립합니다.

suspend fun disconnect()

WebSocket 연결을 종료합니다.

getSubscribedSymbols

fun getSubscribedSymbols(): Set<String>

현재 구독 중인 심볼 목록을 반환합니다.

fun isConnected(): Boolean

연결 상태를 확인합니다.

fun pricesBySymbol(symbol: String): Flow<StreamingPrice>

특정 심볼의 가격 데이터만 필터링한 Flow.

fun quotesBySymbol(symbol: String): Flow<StreamingQuote>

특정 심볼의 상세 시세 데이터만 필터링한 Flow.

suspend fun subscribe(symbol: String)

심볼을 구독합니다.

suspend fun subscribe(symbols: List<String>)

여러 심볼을 구독합니다.

suspend fun unsubscribe(symbol: String)

심볼 구독을 해제합니다.

suspend fun unsubscribe(symbols: List<String>)

여러 심볼의 구독을 해제합니다.

suspend fun unsubscribeAll()

모든 구독을 해제합니다.