Thanks. Given that each call to the api I'm wrapping returns a result and I'm returning this as a materialized value, how should I set this value in the case where the supervision strategy is not applicable. I'm using your azure queue storage code as an example, and am using an IEnumerable as a source. So my graph looks like:
Task<WriteResult> t =
.Select(x => ToEventData(x))
.RunWith(new EventStoreSink(this.Connection, "PasswordChanges"), this.Materializer);
I'm suspecting the stage is only returning the last WriteResult, but I want ot return all of them. Any advise apreciate.