Akka Streams を使用する場合、リソースのクリーンアップに不要になったストリームを閉じる/シャットダウンする方法はありますか?
EDIT : ソースが無限ストリームで構成されている場合、ソースが完成しない可能性があり、ソースが完成する前に停止したいと思います。
使用例:
Source.from(publisher)
.map((p) -> p)
.to(Sink.ignore())
.run(materializer)
ストリームをシャットダウンする方法はありますか?