close method

  1. @override
Future close ()

Closes the stream.

Listeners receive the done event at a later microtask. This behavior can be overridden by using sync controllers. Note, however, that sync controllers have to satisfy the preconditions mentioned in the documentation of the constructors.

Implementation

@override
Future<dynamic> close() {
  if (_isAddingStreamItems) {
    throw StateError(
        "You cannot close the subject while items are being added from addStream");
  }

  return controller.close();
}