Skip to content

Instantly share code, notes, and snippets.

@Jayasagar
Created July 7, 2017 04:29
Show Gist options
  • Save Jayasagar/980cbae1f5bf3cc42293b77529d91d60 to your computer and use it in GitHub Desktop.
Save Jayasagar/980cbae1f5bf3cc42293b77529d91d60 to your computer and use it in GitHub Desktop.
Run the graph
//#errorHandlingClosedRunnableGraph
// Self kill this actor so that BackoffSupervisor starts this actor(pipeline/stream) again!
RunnableGraph.fromGraph(completionStageGraph)
.run(materializer)
.isShutdown()
.whenComplete((done, throwable) -> {
getSelf().tell(PoisonPill.getInstance(), getSelf());
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment