Skip to content

Commit 621e978

Browse files
committed
Recover disabled test
1 parent fc4cfb3 commit 621e978

1 file changed

Lines changed: 10 additions & 14 deletions

File tree

  • sbt-airframe/src/sbt-test/sbt-airframe/rpc-netty/server/src/test/scala/example

sbt-airframe/src/sbt-test/sbt-airframe/rpc-netty/server/src/test/scala/example/MyRPCTest.scala

Lines changed: 10 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -10,20 +10,16 @@ import example.api.MyRPCClient
1010
import example.api.MyRPCClient.RPCSyncClient
1111

1212
class MyRPCTest extends AirSpec {
13+
override protected def design: Design = {
14+
Netty.server.withRouter(MyRPCApi.router).design
15+
.bind[RPCSyncClient].toProvider[NettyServer] { (server: NettyServer) =>
16+
MyRPCClient.newRPCSyncClient(Http.client.newSyncClient(server.localAddress))
17+
}
18+
}
1319

14-
test("RPC test") {
15-
pending("airspec 23.5.5 is required to bind RPCSyncClient properly")
20+
test("Access RPC") { (client: RPCSyncClient) =>
21+
val ret = client.MyRPCApi.helloRPC(HelloRequest("Airframe"))
22+
info(ret)
23+
ret shouldBe HelloResponse("Hello Airframe!")
1624
}
17-
// override protected def design: Design = {
18-
// Netty.server.withRouter(MyRPCApi.router).design
19-
// .bind[RPCSyncClient].toProvider[NettyServer] { (server: NettyServer) =>
20-
// MyRPCClient.newRPCSyncClient(Http.client.newSyncClient(server.localAddress))
21-
// }
22-
// }
23-
//
24-
// test("Access RPC") { (client: RPCSyncClient) =>
25-
// val ret = client.MyRPCApi.helloRPC(HelloRequest("Airframe"))
26-
// info(ret)
27-
// ret shouldBe HelloResponse("Hello Airframe!")
28-
// }
2925
}

0 commit comments

Comments
 (0)