Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
viartemev authored Feb 15, 2019
1 parent 62afdec commit e271224
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ repositories {
jcenter()
}
compile 'com.viartemev:the-white-rabbit:0.0.2'
compile 'com.viartemev:the-white-rabbit:0.0.3'
```
##### Maven:
```
Expand All @@ -26,7 +26,7 @@ compile 'com.viartemev:the-white-rabbit:0.0.2'
<dependency>
<groupId>com.viartemev</groupId>
<artifactId>the-white-rabbit</artifactId>
<version>0.0.2</version>
<version>0.0.3</version>
<type>pom</type>
</dependency>
```
Expand All @@ -37,7 +37,7 @@ compile 'com.viartemev:the-white-rabbit:0.0.2'
connection.confirmChannel {
publish {
coroutineScope {
(1..n).map { async { publishWithConfirm(createMessage("Hello #$it")) } }.awaitAll()
(1..n).map { asyncPublishWithConfirm(createMessage("Hello #$it")) }.awaitAll()
}
}
}
Expand All @@ -47,7 +47,7 @@ or
connection.confirmChannel {
publish {
val messages = (1..n).map { createMessage("Hello #$it") }
publishWithConfirm(messages).awaitAll()
asyncPublishWithConfirm(messages).awaitAll()
}
}
```
Expand All @@ -57,7 +57,7 @@ Consume only n-messages:
```kotlin
connection.channel {
consume(QUEUE_NAME) {
(1..n).map { async { consumeWithConfirm({ println(it) }) } }.awaitAll()
(1..n).map { asyncConsumeWithConfirm({ println(it) }) }.awaitAll()
}
}
```
Expand Down

0 comments on commit e271224

Please sign in to comment.