end method

void end()

Ends the flow and closes its streams. Unsubscribes from the channel so no further events are delivered.

Implementation

void end() {
  if (state == OmegaFlowState.ended) return;
  state = OmegaFlowState.ended;
  onEnd();
  _channelSubscription?.cancel();
  _channelSubscription = null;
  _expressions.close();
}