-//
-// PipedInputStream in = new PipedInputStream() {
-//
-// @Override
-// public void close() throws IOException {
-// System.out.println("Piped IN closing...");
-// super.close();
-// }
-// };
-// CompletableFuture<Void> done = CompletableFuture.runAsync(() -> {
-// try {
-// Binary binary = valueFactory.createBinary(in);
-// content.setProperty(Property.JCR_DATA, binary);
-// saveJcrSession();
-// } catch (RepositoryException e) {
-// throw new JcrException(
-// "Cannot create binary in " + jcrPath + " in workspace " + jcrWorkspace, e);
-// }
-// });
-// PipedOutputStream out = new PipedOutputStream(in) {
-// @Override
-// public void close() throws IOException {
-// super.flush();
-// System.out.println("Piped OUT closing...");
-// super.close();
-// done.join();
-// }
-// };