Skip to content

Commit

Permalink
finish todo
Browse files Browse the repository at this point in the history
  • Loading branch information
rmgk committed Jul 10, 2024
1 parent 5275e87 commit daf10b9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ class DTNRdtClientContext[T: JsonValueCodec](connection: RdtClient, executionCon
override def send(message: ProtocolMessage[T]): Async[Any, Unit] =
message match
case ProtocolMessage.Request(sender, dots) =>
// TODO: how to handle this? We
// TODO: how to handle this? Optimally, this should be answered by sending all known payloads that are larger than the provided set of dots
Sync { () }
case ProtocolMessage.Payload(sender, dots, data) =>
connection.send(writeToArray[T](data), dots).toAsync(using executionContext)
Expand Down

0 comments on commit daf10b9

Please sign in to comment.