You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Maybe the returned Future should be the mat val Future of Sink.ignore?
Then we should maybe also expose that as a getter. Not sure what to name it. def whenStopped: Future[Done].
Purpose of that is to be able to observe that the projection failed/completed for other reasons than stop().
Maybe the returned Future should be the mat val Future of
Sink.ignore
?Then we should maybe also expose that as a getter. Not sure what to name it.
def whenStopped: Future[Done]
.Purpose of that is to be able to observe that the projection failed/completed for other reasons than
stop()
.Originally posted by @patriknw in #35
The text was updated successfully, but these errors were encountered: