Skip to content

add StreamTransformer suport #11

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
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions