Dart Documentation › mongo_dart › ChunkHandler

ChunkHandler class 

class ChunkHandler {
 int chunkSize; 
 List<int> carry;

 ChunkHandler([this.chunkSize = 1024 * 256]);

 void _handle(List<int> data, EventSink<List<int>> sink, bool isClosing) { 
     if (carry != null) {
       carry.addAll(data);
       data = carry;
       carry = null;
     }
     int startPos = 0;
     int pos = 0;
     while (pos + chunkSize < data.length) {        
       sink.add(data.sublist(pos,pos + chunkSize));  
       pos += chunkSize;
     }        
     if (data.length > pos) {
       carry = new List<int>();
       carry.addAll(data.sublist(pos));
       if (isClosing) {
         sink.add(carry);
       }
     }
   }

 void handleData(List<int> data, EventSink<List<int>> sink) {
   _handle(data, sink, false);
 }
 void handleError(Object error, StackTrace stackTrace, EventSink<List<int>> sink) {
   print(error);
   print(stackTrace);
 }
 void handleDone(EventSink<List<int>> sink) {
   _handle([], sink, true);
   sink.close();
 }
 StreamTransformer<List<int>,List<int>> get transformer => new StreamTransformer<List<int>,List<int>>.fromHandlers(
     handleData: handleData,handleDone: handleDone);
}

Constructors

new ChunkHandler([int chunkSize = 1024*256]) #

Creates a new Object instance.

Object instances have no meaningful state, and are only useful through their identity. An Object instance is equal to itself only.

docs inherited from Object 
ChunkHandler([this.chunkSize = 1024 * 256]);

Properties

List<int> carry # 

List<int> carry

int chunkSize # 

int chunkSize

final StreamTransformer<List<int>, List<int>> transformer # 

StreamTransformer<List<int>,List<int>> get transformer => new StreamTransformer<List<int>,List<int>>.fromHandlers(
   handleData: handleData,handleDone: handleDone);

Methods

void handleData(List<int> data, EventSink<List<int>> sink) #

void handleData(List<int> data, EventSink<List<int>> sink) {
 _handle(data, sink, false);
}

void handleDone(EventSink<List<int>> sink) #

void handleDone(EventSink<List<int>> sink) {
 _handle([], sink, true);
 sink.close();
}

void handleError(Object error, StackTrace stackTrace, EventSink<List<int>> sink) #

void handleError(Object error, StackTrace stackTrace, EventSink<List<int>> sink) {
 print(error);
 print(stackTrace);
}