X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.enterprise%2Fsrc%2Forg%2Fargeo%2Futil%2FServiceChannel.java;fp=org.argeo.enterprise%2Fsrc%2Forg%2Fargeo%2Futil%2FServiceChannel.java;h=0000000000000000000000000000000000000000;hb=9f729eeb8255a9d800ad2506735dda8cc215a135;hp=799738414a400181dba447eb7d96cdffec31d823;hpb=f9efbe5228615951dd8482a4582aa24e00c10ce5;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.enterprise/src/org/argeo/util/ServiceChannel.java b/org.argeo.enterprise/src/org/argeo/util/ServiceChannel.java
deleted file mode 100644
index 799738414..000000000
--- a/org.argeo.enterprise/src/org/argeo/util/ServiceChannel.java
+++ /dev/null
@@ -1,78 +0,0 @@
-package org.argeo.util;
-
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.nio.channels.AsynchronousByteChannel;
-import java.nio.channels.CompletionHandler;
-import java.nio.channels.ReadableByteChannel;
-import java.nio.channels.WritableByteChannel;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Future;
-
-/** An {@link AsynchronousByteChannel} based on an {@link ExecutorService}. */
-public class ServiceChannel implements AsynchronousByteChannel {
-	private final ReadableByteChannel in;
-	private final WritableByteChannel out;
-
-	private boolean open = true;
-
-	private ExecutorService executor;
-
-	public ServiceChannel(ReadableByteChannel in, WritableByteChannel out, ExecutorService executor) {
-		this.in = in;
-		this.out = out;
-		this.executor = executor;
-	}
-
-	@Override
-	public Future<Integer> read(ByteBuffer dst) {
-		return executor.submit(() -> in.read(dst));
-	}
-
-	@Override
-	public <A> void read(ByteBuffer dst, A attachment, CompletionHandler<Integer, ? super A> handler) {
-		try {
-			Future<Integer> res = read(dst);
-			handler.completed(res.get(), attachment);
-		} catch (Exception e) {
-			handler.failed(e, attachment);
-		}
-	}
-
-	@Override
-	public Future<Integer> write(ByteBuffer src) {
-		return executor.submit(() -> out.write(src));
-	}
-
-	@Override
-	public <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) {
-		try {
-			Future<Integer> res = write(src);
-			handler.completed(res.get(), attachment);
-		} catch (Exception e) {
-			handler.failed(e, attachment);
-		}
-	}
-
-	@Override
-	public synchronized void close() throws IOException {
-		try {
-			in.close();
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
-		try {
-			out.close();
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
-		open = false;
-		notifyAll();
-	}
-
-	@Override
-	public synchronized boolean isOpen() {
-		return open;
-	}
-
-}