|
1 | 1 | /* |
2 | | - * Copyright 2015-2024 the original author or authors. |
| 2 | + * Copyright 2015-2025 the original author or authors. |
3 | 3 | * |
4 | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
5 | 5 | * you may not use this file except in compliance with the License. |
|
14 | 14 | * limitations under the License. |
15 | 15 | */ |
16 | 16 |
|
17 | | -package io.rsocket.kotlin.transport.ktor.websocket.server |
| 17 | +package io.rsocket.kotlin.transport.ktor.websocket.tests |
18 | 18 |
|
19 | | -import io.ktor.client.engine.* |
20 | | -import io.ktor.server.engine.* |
21 | 19 | import io.rsocket.kotlin.transport.ktor.websocket.client.* |
| 20 | +import io.rsocket.kotlin.transport.ktor.websocket.server.* |
22 | 21 | import io.rsocket.kotlin.transport.tests.* |
| 22 | +import io.ktor.client.engine.cio.CIO as ClientCIO |
| 23 | +import io.ktor.server.cio.CIO as ServerCIO |
23 | 24 |
|
24 | 25 | @Suppress("DEPRECATION_ERROR") |
25 | | -abstract class WebSocketTransportTest( |
26 | | - private val clientEngine: HttpClientEngineFactory<*>, |
27 | | - private val serverEngine: ApplicationEngineFactory<*, *>, |
28 | | -) : TransportTest() { |
| 26 | +class WebSocketTransportTest : TransportTest() { |
29 | 27 | override suspend fun before() { |
30 | 28 | val embeddedServer = startServer( |
31 | | - WebSocketServerTransport(serverEngine, port = 0) |
| 29 | + WebSocketServerTransport(ServerCIO, port = 0) |
32 | 30 | ) |
33 | 31 | val connector = embeddedServer.engine.resolvedConnectors().single() |
34 | 32 | client = connectClient( |
35 | | - WebSocketClientTransport(clientEngine, port = connector.port, context = testContext) |
| 33 | + WebSocketClientTransport(ClientCIO, port = connector.port, context = testContext) |
36 | 34 | ) |
37 | 35 | } |
38 | 36 | } |
39 | 37 |
|
40 | | -abstract class KtorWebSocketTransportTest( |
41 | | - private val clientEngine: HttpClientEngineFactory<*>, |
42 | | - private val serverEngine: ApplicationEngineFactory<*, *>, |
43 | | -) : TransportTest() { |
| 38 | +class KtorWebSocketTransportTest : TransportTest() { |
44 | 39 | override suspend fun before() { |
45 | 40 | val server = startServer( |
46 | 41 | KtorWebSocketServerTransport(testContext) { |
47 | | - httpEngine(serverEngine) |
| 42 | + httpEngine(ServerCIO) |
48 | 43 | }.target(port = 0) |
49 | 44 | ) |
50 | 45 | val port = server.connectors.single().port |
51 | 46 | client = connectClient( |
52 | 47 | KtorWebSocketClientTransport(testContext) { |
53 | | - httpEngine(clientEngine) |
| 48 | + httpEngine(ClientCIO) |
54 | 49 | }.target(port = port) |
55 | 50 | ) |
56 | 51 | } |
|
0 commit comments