start method
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;
});
}