Move termination check to an earlier point.
Move termination check to an earlier point.

reactors-io/reactors,storm-enroute/reactors,storm-enroute/reactors,reactors-io/reactors,storm-enroute/reactors,reactors-io/reactors,storm-enroute/reactive-collections,storm-enroute/reactors,reactors-io/reactors