Skip to content

Commit bb277da

Browse files
authoredJan 31, 2021
feat: add authorized websocket (#216)
1 parent a3ffb33 commit bb277da

File tree

61 files changed

+824
-195
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

61 files changed

+824
-195
lines changed
 

‎reactive-crypto-bhex/src/main/kotlin/com/njkim/reactivecrypto/bhex/BhexWebsocketClient.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,10 @@ import com.njkim.reactivecrypto.core.common.model.order.OrderBookUnit
77
import com.njkim.reactivecrypto.core.common.model.order.TickData
88
import com.njkim.reactivecrypto.core.common.model.order.TradeSideType
99
import com.njkim.reactivecrypto.core.common.util.toEpochMilli
10-
import com.njkim.reactivecrypto.core.websocket.ExchangeWebsocketClient
10+
import com.njkim.reactivecrypto.core.websocket.ExchangePublicWebsocketClient
1111
import reactor.core.publisher.Flux
1212

13-
class BhexWebsocketClient(host: String = "ws.bhex.com") : ExchangeWebsocketClient {
13+
class BhexWebsocketClient(host: String = "ws.bhex.com") : ExchangePublicWebsocketClient {
1414
private val bhexRawWebsocketClient = BhexRawWebsocketClient(host)
1515

1616
override fun createDepthSnapshot(subscribeTargets: List<CurrencyPair>): Flux<OrderBook> {
@@ -44,4 +44,4 @@ class BhexWebsocketClient(host: String = "ws.bhex.com") : ExchangeWebsocketClien
4444
}
4545
}
4646
}
47-
}
47+
}

‎reactive-crypto-bhex/src/test/kotlin/com/njkim/reactivecrypto/bhex/BhexWebsocketClientTest.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -132,4 +132,4 @@ class BhexWebsocketClientTest {
132132
}
133133
.verifyComplete()
134134
}
135-
}
135+
}

0 commit comments

Comments
 (0)
Please sign in to comment.