grpc: Working demo on Desktop and iOS

Author: Jozott00

samples/grpc-kmp-app/composeApp/src/commonMain/kotlin/kotlinx/rpc/sample/App.kt

@@ -95,7 +95,6 @@ private fun ChatScreen(service: MessageService) {
         }
     }
 
-    // Start/refresh the server stream whenever "me" changes
     LaunchedEffect(me) {
         messages.clear()
         val req = ReceiveMessagesRequest { user = me }
@@ -155,17 +154,14 @@ fun MessageBubble(
 ) {
     val isMe = message.user == me
 
-    // bubble colors
     val bubbleColor = if (isMe) MaterialTheme.colorScheme.primary else MaterialTheme.colorScheme.surfaceVariant
     val textColor = if (isMe) Color.White else Color.Black
 
-    // formatted time
     val local = Instant.fromEpochMilliseconds(message.tsMillis)
         .toLocalDateTime(TimeZone.currentSystemDefault())
     // e.g. "14:05"
     val timeText = "${local.hour.toString().padStart(2, '0')}:${local.minute.toString().padStart(2, '0')}"
 
-    // alignment: messages from me align to right, others to left
     Row(
         modifier = modifier
             .fillMaxWidth()

samples/grpc-kmp-app/server/src/main/kotlin/kotlinx/rpc/sample/MessageServiceImpl.kt

@@ -19,7 +19,6 @@ class MessageServiceImpl: MessageService {
     private val bus = MutableSharedFlow<ChatEntry>(extraBufferCapacity = 64, replay = 0)
 
     override suspend fun SendMessage(message: SendMessageRequest): SendMessageResponse {
-        // ensure server timestamp / id if you carry those
         val entry = ChatEntry {
             user = message.user
             text = message.text
@@ -30,7 +29,6 @@ class MessageServiceImpl: MessageService {
     }
 
     override fun ReceiveMessages(message: ReceiveMessagesRequest): Flow<ChatEntry> {
-        // broadcast to everyone
         return bus.asSharedFlow()
             .filter { it.user != message.user }
     }