Skip to content

Commit 5250614

Browse files
vietjvietj
committed
Set next snapshot version
1 parent f6e677d commit 5250614

File tree

14 files changed

+113
-99
lines changed

14 files changed

+113
-99
lines changed

‎pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
<artifactId>vertx-lang-kotlin-parent</artifactId>
1212
<name>Vert.x for Kotlin parent</name>
1313

14-
<version>4.5.22</version>
14+
<version>4.5.23-SNAPSHOT</version>
1515
<packaging>pom</packaging>
1616

1717
<scm>

‎vertx-lang-kotlin-coroutines/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
<parent>
88
<artifactId>vertx-lang-kotlin-parent</artifactId>
99
<groupId>io.vertx</groupId>
10-
<version>4.5.22</version>
10+
<version>4.5.23-SNAPSHOT</version>
1111
</parent>
1212

1313
<properties>

‎vertx-lang-kotlin-gen/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
<parent>
99
<artifactId>vertx-lang-kotlin-parent</artifactId>
1010
<groupId>io.vertx</groupId>
11-
<version>4.5.22</version>
11+
<version>4.5.23-SNAPSHOT</version>
1212
</parent>
1313

1414
<artifactId>vertx-lang-kotlin-gen</artifactId>

‎vertx-lang-kotlin/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
<parent>
99
<artifactId>vertx-lang-kotlin-parent</artifactId>
1010
<groupId>io.vertx</groupId>
11-
<version>4.5.22</version>
11+
<version>4.5.23-SNAPSHOT</version>
1212
</parent>
1313

1414
<artifactId>vertx-lang-kotlin</artifactId>

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/amqp/AmqpClientOptions.kt‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ import java.util.concurrent.TimeUnit
3434
*
3535
* @param activityLogDataFormat Set the value of Netty's logging handler's data format: Netty's pipeline is configured for logging on Netty's logger.
3636
* @param applicationLayerProtocols Set the list of application-layer protocols to provide to the server during the Application-Layer Protocol Negotiation.
37+
* @param authorizationId
3738
* @param connectTimeout
3839
* @param connectionHostname Explicitly override the hostname value used for the AMQP Open frame. The host connected to as per [io.vertx.amqp.AmqpClientOptions] will be used in the Open frame by default.
3940
* @param containerId Sets the container id.
@@ -101,6 +102,7 @@ import java.util.concurrent.TimeUnit
101102
fun amqpClientOptionsOf(
102103
activityLogDataFormat: ByteBufFormat? = null,
103104
applicationLayerProtocols: Iterable<String>? = null,
105+
authorizationId: String? = null,
104106
connectTimeout: Int? = null,
105107
connectionHostname: String? = null,
106108
containerId: String? = null,
@@ -168,6 +170,9 @@ fun amqpClientOptionsOf(
168170
if (applicationLayerProtocols != null) {
169171
this.setApplicationLayerProtocols(applicationLayerProtocols.toList())
170172
}
173+
if (authorizationId != null) {
174+
this.setAuthorizationId(authorizationId)
175+
}
171176
if (connectTimeout != null) {
172177
this.setConnectTimeout(connectTimeout)
173178
}

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/file/AsyncFile.kt‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,6 @@ import io.vertx.core.file.AsyncFileLock
2121
import io.vertx.core.streams.WriteStream
2222
import io.vertx.kotlin.coroutines.awaitResult
2323

24-
/**
25-
* Suspending version of method [io.vertx.core.file.AsyncFile.pipeTo]
26-
*
27-
* @param dst the destination write stream
28-
*
29-
* NOTE: This function has been automatically generated from [io.vertx.core.file.AsyncFile] using Vert.x codegen.
30-
*/
31-
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
32-
suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit {
33-
return awaitResult {
34-
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
35-
}
36-
}
37-
3824
/**
3925
* Suspending version of method [io.vertx.core.file.AsyncFile.write]
4026
*
@@ -76,6 +62,20 @@ suspend fun AsyncFile.endAwait(data: Buffer): Unit {
7662
}
7763
}
7864

65+
/**
66+
* Suspending version of method [io.vertx.core.file.AsyncFile.pipeTo]
67+
*
68+
* @param dst the destination write stream
69+
*
70+
* NOTE: This function has been automatically generated from [io.vertx.core.file.AsyncFile] using Vert.x codegen.
71+
*/
72+
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
73+
suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit {
74+
return awaitResult {
75+
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
76+
}
77+
}
78+
7979
/**
8080
* Suspending version of method [io.vertx.core.file.AsyncFile.close]
8181
*

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/ClientWebSocket.kt‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -23,20 +23,6 @@ import io.vertx.core.http.WebSocketFrame
2323
import io.vertx.core.streams.WriteStream
2424
import io.vertx.kotlin.coroutines.awaitResult
2525

26-
/**
27-
* Suspending version of method [io.vertx.core.http.ClientWebSocket.pipeTo]
28-
*
29-
* @param dst the destination write stream
30-
*
31-
* NOTE: This function has been automatically generated from [io.vertx.core.http.ClientWebSocket] using Vert.x codegen.
32-
*/
33-
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
34-
suspend fun ClientWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
35-
return awaitResult {
36-
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
37-
}
38-
}
39-
4026
/**
4127
* Suspending version of method [io.vertx.core.http.ClientWebSocket.write]
4228
*
@@ -65,6 +51,20 @@ suspend fun ClientWebSocket.endAwait(data: Buffer): Unit {
6551
}
6652
}
6753

54+
/**
55+
* Suspending version of method [io.vertx.core.http.ClientWebSocket.pipeTo]
56+
*
57+
* @param dst the destination write stream
58+
*
59+
* NOTE: This function has been automatically generated from [io.vertx.core.http.ClientWebSocket] using Vert.x codegen.
60+
*/
61+
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
62+
suspend fun ClientWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
63+
return awaitResult {
64+
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
65+
}
66+
}
67+
6868
/**
6969
* Suspending version of method [io.vertx.core.http.ClientWebSocket.end]
7070
*

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/ServerWebSocket.kt‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,6 @@ import io.vertx.core.http.WebSocketFrame
2121
import io.vertx.core.streams.WriteStream
2222
import io.vertx.kotlin.coroutines.awaitResult
2323

24-
/**
25-
* Suspending version of method [io.vertx.core.http.ServerWebSocket.pipeTo]
26-
*
27-
* @param dst the destination write stream
28-
*
29-
* NOTE: This function has been automatically generated from [io.vertx.core.http.ServerWebSocket] using Vert.x codegen.
30-
*/
31-
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
32-
suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
33-
return awaitResult {
34-
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
35-
}
36-
}
37-
3824
/**
3925
* Suspending version of method [io.vertx.core.http.ServerWebSocket.write]
4026
*
@@ -63,6 +49,20 @@ suspend fun ServerWebSocket.endAwait(data: Buffer): Unit {
6349
}
6450
}
6551

52+
/**
53+
* Suspending version of method [io.vertx.core.http.ServerWebSocket.pipeTo]
54+
*
55+
* @param dst the destination write stream
56+
*
57+
* NOTE: This function has been automatically generated from [io.vertx.core.http.ServerWebSocket] using Vert.x codegen.
58+
*/
59+
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
60+
suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
61+
return awaitResult {
62+
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
63+
}
64+
}
65+
6666
/**
6767
* Suspending version of method [io.vertx.core.http.ServerWebSocket.end]
6868
*

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/WebSocket.kt‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,6 @@ import io.vertx.core.http.WebSocketFrame
2121
import io.vertx.core.streams.WriteStream
2222
import io.vertx.kotlin.coroutines.awaitResult
2323

24-
/**
25-
* Suspending version of method [io.vertx.core.http.WebSocket.pipeTo]
26-
*
27-
* @param dst the destination write stream
28-
*
29-
* NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocket] using Vert.x codegen.
30-
*/
31-
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
32-
suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
33-
return awaitResult {
34-
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
35-
}
36-
}
37-
3824
/**
3925
* Suspending version of method [io.vertx.core.http.WebSocket.write]
4026
*
@@ -63,6 +49,20 @@ suspend fun WebSocket.endAwait(data: Buffer): Unit {
6349
}
6450
}
6551

52+
/**
53+
* Suspending version of method [io.vertx.core.http.WebSocket.pipeTo]
54+
*
55+
* @param dst the destination write stream
56+
*
57+
* NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocket] using Vert.x codegen.
58+
*/
59+
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
60+
suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
61+
return awaitResult {
62+
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
63+
}
64+
}
65+
6666
/**
6767
* Suspending version of method [io.vertx.core.http.WebSocket.end]
6868
*

‎vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/WebSocketBase.kt‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -21,20 +21,6 @@ import io.vertx.core.http.WebSocketFrame
2121
import io.vertx.core.streams.WriteStream
2222
import io.vertx.kotlin.coroutines.awaitResult
2323

24-
/**
25-
* Suspending version of method [io.vertx.core.http.WebSocketBase.pipeTo]
26-
*
27-
* @param dst the destination write stream
28-
*
29-
* NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocketBase] using Vert.x codegen.
30-
*/
31-
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
32-
suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit {
33-
return awaitResult {
34-
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
35-
}
36-
}
37-
3824
/**
3925
* Suspending version of method [io.vertx.core.http.WebSocketBase.write]
4026
*
@@ -63,6 +49,20 @@ suspend fun WebSocketBase.endAwait(data: Buffer): Unit {
6349
}
6450
}
6551

52+
/**
53+
* Suspending version of method [io.vertx.core.http.WebSocketBase.pipeTo]
54+
*
55+
* @param dst the destination write stream
56+
*
57+
* NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocketBase] using Vert.x codegen.
58+
*/
59+
@Deprecated(message = "Instead use pipeTo returning a future and chain with coAwait()", replaceWith = ReplaceWith("pipeTo(dst).coAwait()"))
60+
suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit {
61+
return awaitResult {
62+
this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
63+
}
64+
}
65+
6666
/**
6767
* Suspending version of method [io.vertx.core.http.WebSocketBase.writeFrame]
6868
*

0 commit comments

Comments
 (0)