Make the elastic sink a linked transport.

Sending error reponses via err port, success responses via out port. Signed-off-by: Matthias Wahl <mwahl@wayfair.com>
tremor-rs · Jan 25, 2021 · 7617062 · 7617062
1 parent a6906aa
commit 7617062
Show file tree

Hide file tree

Showing 27 changed files with 1,269 additions and 132 deletions.
diff --git a/src/codec/json.rs b/src/codec/json.rs
@@ -59,9 +59,13 @@ impl Codec for JSON {
             let new_len = max(self.string_buffer.capacity(), data.len()) * 2;
             self.string_buffer.reserve(new_len);
         }
-        tremor_value::to_value_with_buffers(data, &mut self.input_buffer, &mut self.string_buffer)
-            .map(Some)
-            .map_err(|e| e.into())
+        tremor_value::parse_to_value_with_buffers(
+            data,
+            &mut self.input_buffer,
+            &mut self.string_buffer,
+        )
+        .map(Some)
+        .map_err(|e| e.into())
     }
     fn encode(&self, data: &Value) -> Result<Vec<u8>> {
         let mut v = Vec::with_capacity(1024);