streamAsModel<MT extends StorageModel> method

Stream<MT> streamAsModel<MT extends StorageModel>([
  1. Duration delayCheck = const Duration(milliseconds: 50)
])

Implementation

Stream<MT> streamAsModel<MT extends StorageModel>([
  Duration delayCheck = const Duration(milliseconds: 50),
]) => stream(delayCheck: delayCheck).asyncExpand<MT>((data) async* {
  if (data != null) yield data.toModel<MT>();
});