Skip to content

Commit

Permalink
mods-suite: small fixes for ArrayUnwrapMod
Browse files Browse the repository at this point in the history
  • Loading branch information
akolomentsev committed Mar 30, 2018
1 parent a6cae12 commit 4e766a3
Show file tree
Hide file tree
Showing 4 changed files with 14 additions and 5 deletions.
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
group=com.satori
version=0.5.8-SNAPSHOT
version=0.5.9-SNAPSHOT

#nexusUsername=
#nexusPassword=
Expand Down
4 changes: 2 additions & 2 deletions libs/gtfs/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,13 @@ classes are generated based on [gtfs-realtime.proto](https://developers.google.c
<dependency>
<groupId>com.satori</groupId>
<artifactId>satori-libs-gtfs</artifactId>
<version>0.5.8-SNAPSHOT</version>
<version>0.5.9-SNAPSHOT</version>
</dependency>
```


### Download
[satori-libs-gtfs.v0.5.8-SNAPSHOT.zip](https://github.com/satori-com/satori-composer/releases/download/v0.5.8-SNAPSHOT/satori-libs-gtfs.v0.5.8-SNAPSHOT.zip)<br/>
[satori-libs-gtfs.v0.5.9-SNAPSHOT.zip](https://github.com/satori-com/satori-composer/releases/download/v0.5.9-SNAPSHOT/satori-libs-gtfs.v0.5.9-SNAPSHOT.zip)<br/>
[or see latest releases](https://github.com/satori-com/satori-composer/releases/latest)

### Examples
Expand Down
9 changes: 9 additions & 0 deletions mods-suite/src/com/satori/mods/suite/ArrayUnwrapMod.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,9 @@ public ArrayUnwrapMod(JsonNode settings) {
}

public ArrayUnwrapMod(String path) {
if (path != null && !path.startsWith("/")) {
path = "/" + path;
}
this.path = path;
}

Expand Down Expand Up @@ -117,6 +120,12 @@ private void yieldLoop(ArrayDeque<JsonNode> deq, IAsyncHandler cont) {
if (!future.isCompleted()) {
// operation still in progress, set continuation and exit
future.onCompleted(ar -> {

if (!ar.isSucceeded()) {
// log error if processing failed
log.warn("failed to process array element", ar.getError());
}

try {
yieldLoop(deq, cont);
} catch (Exception e) {
Expand Down
4 changes: 2 additions & 2 deletions readme.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
## Satori Composer (preview)
[![Build Status](https://travis-ci.org/satori-com/satori-composer.svg?branch=dev)](https://travis-ci.org/satori-com/satori-composer)
[![Build Status](https://img.shields.io/nexus/s/https/oss.sonatype.org/com.satori/satori-composer.svg)](https://oss.sonatype.org/content/repositories/snapshots/com/satori/satori-composer/0.5.8-SNAPSHOT/)
[![Build Status](https://img.shields.io/nexus/s/https/oss.sonatype.org/com.satori/satori-composer.svg)](https://oss.sonatype.org/content/repositories/snapshots/com/satori/satori-composer/0.5.9-SNAPSHOT/)

#### Example
![diagram](docs/files/big-blue-bus-composition.png)
Expand Down Expand Up @@ -89,7 +89,7 @@
<dependency>
<groupId>com.satori</groupId>
<artifactId>satori-composer</artifactId>
<version>0.5.8-SNAPSHOT</version>
<version>0.5.9-SNAPSHOT</version>
</dependency>
```

Expand Down

0 comments on commit 4e766a3

Please sign in to comment.