fix LockPoint

Author: lecousin

net.lecousin.core/src/main/java/net/lecousin/framework/concurrent/async/LockPoint.java

@@ -30,20 +30,21 @@ public void lock() {
 			return;
 		if (error != null)
 			return;
-		Blockable blockable;
 		do {
+			Blockable blockable;
 			synchronized (this) {
 				if (!locked) {
 					locked = true;
 					return;
 				}
 				blockable = Threading.getBlockable();
-				if (blockable != null) break;
-				try { this.wait(0); }
-				catch (InterruptedException e) { /* continue anyway */ }
+				if (blockable == null)
+					try { this.wait(0); }
+					catch (InterruptedException e) { /* continue anyway */ }
 			}
+			if (blockable != null)
+				blockable.blocked(this, 0);
 		} while (true);
-		blockable.blocked(this, 0);
 	}
 
 	/** Release the lock. */

net.lecousin.core/src/main/java/net/lecousin/framework/io/out2in/OutputToInput.java

@@ -215,12 +215,11 @@ public AsyncSupplier<Integer, IOException> readAsync(long pos, ByteBuffer buffer
 			int lim = buffer.limit();
 			if (writePos - pos < buffer.remaining())
 				buffer.limit(buffer.position() + (int)(writePos - pos));
-			AsyncSupplier<Integer, IOException> read = ((IO.Readable.Seekable)io).readAsync(pos, buffer, ondone);
-			read.onDone(() -> {
+			((IO.Readable.Seekable)io).readAsync(pos, buffer, res -> {
 				buffer.limit(lim);
 				lockIO.unlock();
-				read.forward(result);
-			});
+				if (ondone != null) ondone.accept(res);
+			}).forward(result);
 			return null;
 		}).start();
 		return operation(result);