@@ -39,27 +39,24 @@ RSocket interface contains 5 methods:
3939 ` suspend fun metadataPush(metadata: ByteReadPacket) `
4040
4141## Using in your projects
42- The ` master ` branch is now dedicated to development of multiplatform rsocket-kotlin. For now only snapshots are available
43- via [ oss.jfrog.org] ( https://oss.jfrog.org/artifactory/oss-snapshot-local/io/rsocket/kotlin/ ) (OJO).
44-
4542Make sure, that you use Kotlin 1.4.X.
4643
4744### Gradle:
4845
4946
5047``` groovy
5148repositories {
52- maven { url 'https://oss.jfrog.org/oss-snapshot-local' }
49+ jcenter()
5350}
5451dependencies {
55- implementation 'io.rsocket.kotlin:rsocket-core:0.11.0-SNAPSHOT '
56- implementation 'io.rsocket.kotlin:rsocket-transport-ktor:0.11.0-SNAPSHOT '
52+ implementation 'io.rsocket.kotlin:rsocket-core:0.11.1 '
53+ implementation 'io.rsocket.kotlin:rsocket-transport-ktor:0.11.1 '
5754
5855// client feature for ktor
59- // implementation 'io.rsocket.kotlin:rsocket-transport-ktor-client:0.11.0-SNAPSHOT '
56+ // implementation 'io.rsocket.kotlin:rsocket-transport-ktor-client:0.11.1 '
6057
6158// server feature for ktor
62- // implementation 'io.rsocket.kotlin:rsocket-transport-ktor-server:0.11.0-SNAPSHOT '
59+ // implementation 'io.rsocket.kotlin:rsocket-transport-ktor-server:0.11.1 '
6360
6461// one of ktor engines to work with websockets
6562// client engines
@@ -79,17 +76,17 @@ dependencies {
7976
8077``` kotlin
8178repositories {
82- maven( " https://oss.jfrog.org/oss-snapshot-local " )
79+ jcenter( )
8380}
8481dependencies {
85- implementation(" io.rsocket.kotlin:rsocket-core:0.11.0-SNAPSHOT " )
86- implementation(" io.rsocket.kotlin:rsocket-transport-ktor:0.11.0-SNAPSHOT " )
82+ implementation(" io.rsocket.kotlin:rsocket-core:0.11.1 " )
83+ implementation(" io.rsocket.kotlin:rsocket-transport-ktor:0.11.1 " )
8784
8885// client feature for ktor
89- // implementation("io.rsocket.kotlin:rsocket-transport-ktor-client:0.11.0-SNAPSHOT ")
86+ // implementation("io.rsocket.kotlin:rsocket-transport-ktor-client:0.11.1 ")
9087
9188// server feature for ktor
92- // implementation("io.rsocket.kotlin:rsocket-transport-ktor-server:0.11.0-SNAPSHOT ")
89+ // implementation("io.rsocket.kotlin:rsocket-transport-ktor-server:0.11.1 ")
9390
9491// one of ktor engines to work with websockets
9592// client engines
@@ -123,8 +120,8 @@ val client = HttpClient(CIO) {
123120 )
124121
125122 // payload for setup frame
126- setupPayload { Payload (" hello world" ) }
127-
123+ setupPayload { buildPayload { data (" hello world" ) } }
124+
128125 // mime types
129126 payloadMimeType = PayloadMimeType (
130127 data = " application/json" ,
@@ -167,7 +164,7 @@ embeddedServer(CIO) {
167164 forConnection(::SomeConnectionInterceptor )
168165 }
169166 }
170- }
167+ }
171168 // configure routing
172169 routing {
173170 // configure route `url:port/rsocket`
@@ -177,18 +174,21 @@ embeddedServer(CIO) {
177174 requestResponse { request: Payload ->
178175 // ... some work here
179176 delay(500 ) // work emulation
180- Payload (" data" , " metadata" )
181- }
177+ buildPayload {
178+ data(" data" )
179+ metadata(" metadata" )
180+ }
181+ }
182182 // handler for request/stream
183183 requestStream { request: Payload ->
184184 flow {
185- repeat(1000 ) { i ->
186- emit(Payload (" data: $i " ))
187- }
188- }
189- }
190- }
191- }
185+ repeat(1000 ) { i ->
186+ emit(buildPayload { data (" data: $i " ) } )
187+ }
188+ }
189+ }
190+ }
191+ }
192192 }
193193}.start(true )
194194```
0 commit comments