getOrCreateStreamController<T> static method

StreamController<T> getOrCreateStreamController<T>(
  1. Readable<T> readable
)

Implementation

static StreamController<T> getOrCreateStreamController<T>(
    Readable<T> readable) {
  StreamController<T>? controller =
      _readableStreams[readable] as StreamController<T>?;

  if (controller == null) {
    final newController = createWatchedStreamController(readable);
    _readableStreams[readable] = newController;
    controller = newController;
  }

  return controller;
}