fix: unit of requestTimeoutMs (#203)

Author: alissa-tung

client/src/main/kotlin/io/hstream/impl/HStreamClientKtImpl.kt

@@ -113,8 +113,8 @@ class HStreamClientKtImpl(
         return HStreamApiGrpcKt.HStreamApiCoroutineStub(channelProvider.get(url))
     }
 
-    fun getCoroutineStubWithTimeout(url: String, timeoutSeconds: Long = requestTimeoutMs): HStreamApiGrpcKt.HStreamApiCoroutineStub {
-        return HStreamApiGrpcKt.HStreamApiCoroutineStub(channelProvider.get(url)).withDeadlineAfter(timeoutSeconds, TimeUnit.SECONDS)
+    fun getCoroutineStubWithTimeoutMs(url: String, timeoutMs: Long = requestTimeoutMs): HStreamApiGrpcKt.HStreamApiCoroutineStub {
+        return HStreamApiGrpcKt.HStreamApiCoroutineStub(channelProvider.get(url)).withDeadlineAfter(timeoutMs, TimeUnit.MILLISECONDS)
     }
 
     init {

client/src/main/kotlin/io/hstream/impl/ProducerKtImpl.kt

@@ -141,7 +141,7 @@ open class ProducerKtImpl(
         val serverUrl = lookupServerUrl(shardId, forceUpdate)
         logger.debug("try append with serverUrl [{}], current left tryTimes is [{}]", serverUrl, tryTimes)
         return try {
-            client.getCoroutineStubWithTimeout(serverUrl, requestTimeoutMs)
+            client.getCoroutineStubWithTimeoutMs(serverUrl, requestTimeoutMs)
                 .append(appendRequest).recordIdsList.map(GrpcUtils::recordIdFromGrpc)
         } catch (e: StatusException) {
             handleGRPCException(serverUrl, e)

client/src/main/kotlin/io/hstream/impl/ReaderKtImpl.kt

@@ -51,7 +51,7 @@ class ReaderKtImpl(
         readerScope.launch {
             try {
                 val readShardRequest = ReadShardRequest.newBuilder().setReaderId(readerId).setMaxRecords(maxRecords).build()
-                val readShardResponse = client.getCoroutineStubWithTimeout(serverUrl, requestTimeoutMs)
+                val readShardResponse = client.getCoroutineStubWithTimeoutMs(serverUrl, requestTimeoutMs)
                     .readShard(readShardRequest)
                 val res = readShardResponse.receivedRecordsList.flatMap {
                     RecordUtils.decompress(it).map { receivedHStreamRecord ->
@@ -83,7 +83,7 @@ class ReaderKtImpl(
             .setReaderId(readerId)
             .build()
         runBlocking {
-            client.getCoroutineStubWithTimeout(serverUrl, requestTimeoutMs).deleteShardReader(deleteShardReaderRequest)
+            client.getCoroutineStubWithTimeoutMs(serverUrl, requestTimeoutMs).deleteShardReader(deleteShardReaderRequest)
         }
 
         logger.info("Reader [{}] closed", readerId)