=str Deprecate InvalidAbsorbTermination, please use GraphStage instead. (#20288) (#20386)

This commit is contained in:
Richard Imaoka 2016-06-25 18:37:22 +09:00 committed by Konrad Malawski
parent e8b4ca2acd
commit 1ca40730ef

View file

@ -550,6 +550,8 @@ class InterpreterSpec extends AkkaSpec with GraphInterpreterSpecKit {
}
//#20386
@deprecated("Usage of PushPullStage is deprecated, please use GraphStage instead", "2.4.5")
class InvalidAbsorbTermination extends PushPullStage[Int, Int] {
override def onPull(ctx: Context[Int]): SyncDirective = ctx.pull()
override def onPush(elem: Int, ctx: Context[Int]): SyncDirective = ctx.push(elem)