For a single item, it's probably a better approach to use "Observable…

….just".
spinnaker · Jan 28, 2016 · e205888 · e205888
1 parent 0d79d03
commit e205888
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...triggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java b/...triggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java
@@ -52,8 +52,8 @@ public void processEvent(Event event) {
       return;
     }
 
-    val buildEvent = objectMapper.convertValue(event, BuildEvent.class);
-    Observable.from(Collections.singletonList(buildEvent))
+    BuildEvent buildEvent = objectMapper.convertValue(event, BuildEvent.class);
+    Observable.just(buildEvent)
       .doOnNext(this::onEchoResponse)
       .subscribe(triggerEachMatchFrom(pipelineCache.getPipelines()));
   }