ResultsStream constructor

ResultsStream(
  1. int? insertId,
  2. int? affectedRows,
  3. List<Field>? fields, {
  4. Stream<ResultRow>? stream,
})

Implementation

factory ResultsStream(int? insertId, int? affectedRows, List<Field>? fields,
    {Stream<ResultRow>? stream}) {
  if (stream != null) {
    var newStream = stream.transform(StreamTransformer.fromHandlers(
        handleDone: (EventSink<ResultRow> sink) {
      sink.close();
    }));
    return ResultsStream._fromStream(
        insertId, affectedRows, fields, newStream);
  } else {
    var newStream = Stream.fromIterable(<ResultRow>[]);
    return ResultsStream._fromStream(
        insertId, affectedRows, fields, newStream);
  }
}