Skip to content

Commit

Permalink
changes per review
Browse files Browse the repository at this point in the history
  • Loading branch information
Gilad Hoch committed Nov 12, 2017
1 parent ef2beb8 commit 4de4f35
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion server/cmwell-ws/app/cmwell/ws/Streams.scala
Expand Up @@ -106,7 +106,7 @@ object Streams extends LazyLogging {
.mapAsyncUnordered(parallelism)(str => crudServiceFS.getInfotonByUuidAsync(str.uuid, nbg))
.collect{ case FullBox(i) => i}

def searchThinResultsFlattened: Flow[SearchThinResults,SearchThinResult,NotUsed] = Flow[SearchThinResults]
val searchThinResultsFlattened: Flow[SearchThinResults,SearchThinResult,NotUsed] = Flow[SearchThinResults]
.mapConcat { case SearchThinResults(_, _, _, str, _) => str.toList }

def searchThinResultsToFatInfotons(nbg: Boolean, crudServiceFS: CRUDServiceFS): Flow[SearchThinResults,Infoton,NotUsed] =
Expand Down

0 comments on commit 4de4f35

Please sign in to comment.