Skip to content

Commit 0ad1e3f

Browse files
committed
fix cross-compilation errors and address copilot comments
1 parent 6f10c73 commit 0ad1e3f

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

client-server-client/src/main/scala/zio/raft/client/RaftClient.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -547,8 +547,7 @@ object RaftClient {
547547
} yield copy(pendingRequests = newPending)
548548
case StreamEvent.Action(ClientAction.SubmitQuery(payload, promise)) =>
549549
for {
550-
now <- Clock.instant
551-
// correlationId via client-side generator (to be implemented in T024)
550+
now <- Clock.instant
552551
correlationId <- Random.nextUUID.map(u => CorrelationId.fromString(u.toString))
553552
newPending = pendingQueries.add(correlationId, payload, promise, now)
554553
_ <- transport.sendMessage(Query(correlationId, payload, now)).orDie

client-server-client/src/test/scala/zio/raft/client/PendingQueriesSpec.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,10 @@ object PendingQueriesSpec extends ZIOSpecDefault {
1919
pq = PendingQueries.empty.add(CorrelationId.fromString("c1"), ByteVector(1,2,3), p, now)
2020
sentRef <- Ref.make(0)
2121
transport = new ClientTransport {
22-
def connect(address: String) = ZIO.unit
23-
def disconnect() = ZIO.unit
24-
def sendMessage(message: ClientMessage) = sentRef.update(_ + 1).unit
25-
def incomingMessages = ZStream.empty
22+
override def connect(address: String): ZIO[Any, Throwable, Unit] = ZIO.unit
23+
override def disconnect(): ZIO[Any, Throwable, Unit] = ZIO.unit
24+
override def sendMessage(message: ClientMessage): ZIO[Any, Throwable, Unit] = sentRef.update(_ + 1).unit
25+
override def incomingMessages: ZStream[Any, Throwable, ServerMessage] = ZStream.empty
2626
}
2727
_ <- pq.resendAll(transport)
2828
sent <- sentRef.get
@@ -44,10 +44,10 @@ object PendingQueriesSpec extends ZIOSpecDefault {
4444
for {
4545
sentRef <- Ref.make(0)
4646
transport = new ClientTransport {
47-
def connect(address: String) = ZIO.unit
48-
def disconnect() = ZIO.unit
49-
def sendMessage(message: ClientMessage) = sentRef.update(_ + 1).unit
50-
def incomingMessages = ZStream.empty
47+
override def connect(address: String): ZIO[Any, Throwable, Unit] = ZIO.unit
48+
override def disconnect(): ZIO[Any, Throwable, Unit] = ZIO.unit
49+
override def sendMessage(message: ClientMessage): ZIO[Any, Throwable, Unit] = sentRef.update(_ + 1).unit
50+
override def incomingMessages: ZStream[Any, Throwable, ServerMessage] = ZStream.empty
5151
}
5252

5353
now <- Clock.instant

0 commit comments

Comments
 (0)