} catch (InterruptedException ex) {
Thread.interrupted();
}
bytes = new BytesArray(new byte[]{contentBytes[i]});
client.execute(PutChunkAction.INSTANCE,
new PutChunkRequest(
BlobIndices.fullIndexName("test"), digest,
startBlobRequest.transferId(), bytes, i,
(i + 1) == content.length())
).actionGet();
}