From 5228cf5a04e0f4531cb016fae774116dc866fd3a Mon Sep 17 00:00:00 2001 From: fgreg Date: Wed, 9 Mar 2016 12:24:07 -0800 Subject: [PATCH] Update stream.py Fix for https://github.com/spring-projects/spring-xd/issues/1903 --- spring-xd-python/src/springxd/stream.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-xd-python/src/springxd/stream.py b/spring-xd-python/src/springxd/stream.py index 7f8ea1ff2..291f49579 100644 --- a/spring-xd-python/src/springxd/stream.py +++ b/spring-xd-python/src/springxd/stream.py @@ -43,9 +43,9 @@ def encode(self,data): ''' def decode(self,data): if self.encoder == Encoders.CRLF: - data.rstrip("\r\n") + data = data.rstrip("\r\n") elif self.encoder == Encoders.LF: - data.rstrip("\n") + data = data.rstrip("\n") return data '''