Class SocketOutputStream

test/extra/SendFile.java:13–45

public class SendFile {
  private static class SocketOutputStream extends OutputStream {
    private final SocketChannel channel;
    private final Selector selector;
    public SocketOutputStream(String host, int port) throws Exception {
      channel = SocketChannel.open();
      channel.connect(new InetSocketAddress(host, port));
      channel.configureBlocking(false);
      selector = Selector.open();
      channel.register(selector, SelectionKey.OP_WRITE, null);
    }

    public void close() throws IOException {
      channel.close();
    }

    public void write(int c) {
      throw new RuntimeException("Do not use!");
    }
    public void write(byte[] buffer, int offset, int length)
      throws IOException {
      ByteBuffer buf = ByteBuffer.wrap(buffer);
      buf.position(offset);
      buf.limit(offset+length);
      while (buf.hasRemaining()) {
        selector.select(10000);
        for (SelectionKey key : selector.selectedKeys()) {
          if (key.isWritable() && (key.channel() == channel)) {
            channel.write(buf);
          }
        }
      }
    }
  }

  public static void sendFile(String file, String host, int port)
    throws Exception {