4.11.0

Author: krystianity

CHANGELOG.md

@@ -1,5 +1,9 @@
 # kafka-streams CHANGELOG
 
+## 2019-05-16, Version 4.11.0
+
+* added continueWith dsl operation
+
 ## 2019-05-13, Version 4.10.0
 
 * fixed typo that broke window functionality

docs/doc.md

@@ -781,6 +781,7 @@ Stream base class
     * [.skipWhile(pred)](#StreamDSL+skipWhile) ⇒ [<code>StreamDSL</code>](#StreamDSL)
     * [.until(signal$)](#StreamDSL+until) ⇒ [<code>StreamDSL</code>](#StreamDSL)
     * [.since(signal$)](#StreamDSL+since) ⇒ [<code>StreamDSL</code>](#StreamDSL)
+    * [.continueWith(f)](#StreamDSL+continueWith)
     * [.reduce(eff, initial)](#StreamDSL+reduce) ⇒ <code>\*</code>
     * [.chainReduce(eff, initial, callback)](#StreamDSL+chainReduce) ⇒ [<code>StreamDSL</code>](#StreamDSL)
     * [.drain()](#StreamDSL+drain) ⇒ <code>\*</code>
@@ -1303,6 +1304,18 @@ signal$ must be a most stream instance
 | --- |
 | signal$ | 
 
+<a name="StreamDSL+continueWith"></a>
+
+# streamDSL.continueWith(f)
+Replace the end signal with a new stream returned by f.
+Note that f must return a (most.js) stream.
+
+**Kind**: instance method of [<code>StreamDSL</code>](#StreamDSL)  
+
+| Param | Description |
+| --- | --- |
+| f | function (must return a most stream) |
+
 <a name="StreamDSL+reduce"></a>
 
 # streamDSL.reduce(eff, initial) ⇒ <code>\*</code>

docs/jsdoc/JSKafkaClient.html

@@ -1708,7 +1708,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KStorage.html

@@ -166,7 +166,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KStorage.js.html

@@ -134,7 +134,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KStream.html

@@ -2139,7 +2139,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KTable.html

@@ -2263,7 +2263,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KafkaFactory.html

@@ -224,7 +224,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KafkaFactory.js.html

@@ -84,7 +84,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>

docs/jsdoc/KafkaStreams.html

@@ -1098,7 +1098,7 @@ <h2><a href="index.html">Home</a></h2><h3>Classes</h3><ul><li><a href="JSKafkaCl
 <br class="clear">
 
 <footer>
-    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Mon May 13 2019 09:55:08 GMT+0200 (Central European Summer Time)
+    Documentation generated by <a href="https://github.com/jsdoc/jsdoc">JSDoc 3.6.1</a> on Fri May 17 2019 00:30:02 GMT+0200 (Central European Summer Time)
 </footer>
 
 <script> prettyPrint(); </script>