Re: [Statefun] Exception occurs during function chaining / Async function

2021-03-01 Thread Seth Wiesman
Hi Le, I believe the issue is the bounded source[1]. Stateful Functions only supports unbounded inputs. Additionally, you can remove all the `synchronized` blocks from your code; statefun handles all synchronization for you. Seth [1] https://gist.github.com/flint-stone/cbc60f2d41507fdf33507ba99

[Statefun] Exception occurs during function chaining / Async function

2021-02-26 Thread Le Xu
Hello! I'm getting an exception running a modified version of datastream/statefun example. (See exception details that follow.) The example was adapted from the original datastream example provided in statefun repo. I was trying to play with the example by chaining two functions (with the 1st func