File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -12,7 +12,7 @@ repositories {
1212 jcenter()
1313}
1414
15- compile 'com.viartemev:the-white-rabbit:0.0.2 '
15+ compile 'com.viartemev:the-white-rabbit:0.0.3 '
1616```
1717##### Maven:
1818```
@@ -26,7 +26,7 @@ compile 'com.viartemev:the-white-rabbit:0.0.2'
2626<dependency>
2727 <groupId>com.viartemev</groupId>
2828 <artifactId>the-white-rabbit</artifactId>
29- <version>0.0.2 </version>
29+ <version>0.0.3 </version>
3030 <type>pom</type>
3131</dependency>
3232```
@@ -37,7 +37,7 @@ compile 'com.viartemev:the-white-rabbit:0.0.2'
3737connection.confirmChannel {
3838 publish {
3939 coroutineScope {
40- (1 .. n).map { async { publishWithConfirm (createMessage(" Hello #$it " )) } }.awaitAll()
40+ (1 .. n).map { asyncPublishWithConfirm (createMessage(" Hello #$it " )) }.awaitAll()
4141 }
4242 }
4343}
4747connection.confirmChannel {
4848 publish {
4949 val messages = (1 .. n).map { createMessage(" Hello #$it " ) }
50- publishWithConfirm (messages).awaitAll()
50+ asyncPublishWithConfirm (messages).awaitAll()
5151 }
5252}
5353```
@@ -57,7 +57,7 @@ Consume only n-messages:
5757``` kotlin
5858connection.channel {
5959 consume(QUEUE_NAME ) {
60- (1 .. n).map { async { consumeWithConfirm ({ println (it) }) } }.awaitAll()
60+ (1 .. n).map { asyncConsumeWithConfirm ({ println (it) }) }.awaitAll()
6161 }
6262}
6363```
You can’t perform that action at this time.
0 commit comments