stream method

Stream stream({
  1. dynamic delayCheck = const Duration(milliseconds: 50),
})

Implementation

Stream stream({delayCheck = const Duration(milliseconds: 50)}) async* {
  String streamId = randomStreamId;

  storageListeners.initStream(path, streamId);

  while (true) {
    await Future.delayed(delayCheck);

    Map dates = storageListeners.getDates(path, streamId);

    if (dates["set_date"] >= dates["get_date"]) {
      yield await get(streamId: streamId);
    }
  }
}