+ protected void consumeAllData(AllData allData) {
+ synchronized (this) {
+ String contentType = allData.getContentType();
+ long dataLength = allData.getDataLength();
+ try {
+ InputStream payload = new TempInputStream(allData.getPayloadInputStream(), dataLength);
+ setResult(Optional.of(createData(contentType, dataLength, payload)));
+ } catch (IOException e) {
+ // TODO – logging
+ finish();
+ }
+ }