From e2058886ee50cf0d4e70ecce35a25ebf2c690d06 Mon Sep 17 00:00:00 2001 From: edisonH Date: Thu, 28 Jan 2016 11:34:52 +0800 Subject: [PATCH] For a single item, it's probably a better approach to use "Observable.just". --- .../spinnaker/echo/pipelinetriggers/BuildEventMonitor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java b/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java index 5b76cffee..e75309cad 100644 --- a/echo-pipelinetriggers/src/main/java/com/netflix/spinnaker/echo/pipelinetriggers/BuildEventMonitor.java +++ b/echo-pipelinetriggers/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())); }