- PipedOutputStream out = new PipedOutputStream(in) {
-
- @Override
- public void close() throws IOException {
- super.flush();
- super.close();
- done.join();
-// Binary binary = done.join();
-// try {
-// content.setProperty(Property.JCR_DATA, binary);
-// } catch (RepositoryException e) {
-// throw new JcrException(
-// "Cannot write binary to " + jcrPath + " in workspace " + jcrWorkspace, e);
-// }
+//
+// 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);