From 588e68f0144e9ce5c3e357eb7a146c4c626a1b30 Mon Sep 17 00:00:00 2001
From: markfisher <mfisher@pivotal.io>
Date: Fri, 14 Oct 2016 20:46:02 -0400
Subject: [PATCH] updated Example

---
 .../springframework/cloud/function/compiler/Example.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/Example.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/Example.java
index 2fd1bd0e4..f949990af 100644
--- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/Example.java
+++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/Example.java
@@ -36,8 +36,8 @@ public class Example {
 		CompiledFunctionFactory<Function<Flux<String>,Flux<String>>> functionFactory = functionCompiler.compile("f", "f->f.map(s->s.toString().toUpperCase())");
 		Flux<String> output = functionFactory.getResult().apply(input);
 
-		ConsumerCompiler<Flux<String>> consumerCompiler = new ConsumerCompiler<>();
-		CompiledFunctionFactory<Consumer<Flux<String>>> consumerFactory = consumerCompiler.compile("c", "f->f.subscribe(System.out::println)");
-		consumerFactory.getResult().accept(output);
+		ConsumerCompiler<String> consumerCompiler = new ConsumerCompiler<>();
+		CompiledFunctionFactory<Consumer<String>> consumerFactory = consumerCompiler.compile("c", "System.out::println");
+		output.subscribe(consumerFactory.getResult());
 	}
 }