start method

Future<Stream<DataBody>> start()

Starts transmission from server.

Implementation

Future<Stream<DataBody>> start() async {
  var bufferedStream = bufferedListStream(await startCore(), bufferSize);
  return bufferedStream.map((bytes) {
    var body = _createDataBody(bytes);
    var newState = initialState.start + _transferred > initialState.end
        ? null
        : ConnState(initialState.id, initialState.start + _transferred,
            initialState.end);
    onStateChange?.call(newState);
    return body;
  });
}