HttpServerImpl.java

private void doRead(SocketChannel socketChannel) throws NioHttpServerException {
    try {
      ByteBuffer buf = ByteBuffer.allocate(1024);
      socketChannel.read(buf);
      buf.flip();

      Option<Request> maybeRequest = requestHandler.apply(buf);
      buf.clear();

      Option<Either<Exception, Response>> maybeResponse =
          maybeRequest.map(
              request -> {
                try {
                  Response response = responseHandler.apply(request);
                  socketChannel.write(response.toByteBuf());
                  return Either.right(response);
                } catch (NioHttpServerException | IOException err) {
                  return Either.left(err);
                }
              });

      if (maybeResponse.isSome() && maybeResponse.some().isLeft()) {
        throw new NioHttpServerException(maybeResponse.some().left().value());
      }
    } catch (IOException e) {
      throw new NioHttpServerException(e);
    } finally {
      LOGGER.info("Disconnected: %s", socketChannel.socket().getRemoteSocketAddress().toString());
      try {
        socketChannel.close();
      } catch (IOException e) {
        throw new NioHttpServerException(e);
      }
    }
  }