Skip to content

add StreamTransformer suport #11

@insinfo

Description

@insinfo

add StreamTransformer suport

import 'dart:convert';
import 'dart:io';

import 'package:csv/csv.dart';
import 'package:enough_convert/enough_convert.dart';

void main(List<String> args) async {
  final input = new File(
          'C:/MyDartProjects/notifis/notifis_backend/db/planilhas/CIP 2012.csv')
      .openRead();

  final codec = const Windows1252Codec(allowInvalid: false);
  final stream =  await input.transform(codec).transform(LineSplitter());
  await for (var lineString in stream) {
    var rowsAsListOfValues =
        CsvToListConverter(fieldDelimiter: ';').convert(lineString);
    var lineCsv = rowsAsListOfValues.first;
    print(lineCsv.map((e) => '$e').join(' | '));
  }

  exit(0);
}

image

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions