Servlet 3.1 non blocking IO integration

[Stefano Marocco]

HI,

i integrating a servlet based application with Akka Streams.

I need implement a process for take in input a servlet input stream, parse request with Commons FileUpload and produce a response.


class MyReadListener implements ReadListener
{
    private final ServletInputStream servletInputStream;
   
    private Promise<Optional<ByteString>> promise = FutureConverters.promise();
   
    public My(ServletInputStream servletInputStream)
    {
        this.servletInputStream = servletInputStream;
       
        servletInputStream.setReadListener(this);
    }

    @Override
    public void onDataAvailable() throws IOException
    {
        readData();
    }
   
    private void readData() throws IOException
    {
        if (promise.isCompleted())
        {   
            return;
        }
       
        if (servletInputStream.isFinished())       
        {
            promise.success(Optional.empty());
        }
        else
        {
            if (servletInputStream.isReady())
            {
                if (!servletInputStream.isFinished())
                {
                    byte[] data = new byte[16];
                    int count;
                    count = servletInputStream.read(data);
                    System.out.println(count);
                    promise.success(Optional.of(ByteString.fromArray(data, 0, count)));
                }
            }
        }
       
    }

    @Override
    public void onAllDataRead() throws IOException
    {
    }

    @Override
    public void onError(Throwable t)
    {
        promise.failure(t);
    }
   
    public Promise<Optional<ByteString>> cs()
    {
        try
        {
            readData();
           
            return promise;
        }
        catch (IOException e)
        {
            return promise.failure(e);
        }
        finally
        {
            promise = FutureConverters.promise();
        }
    }
}


...


AsyncContext ctx = req.startAsync(req, resp);

        ServletInputStream servletInputStream = ctx.getRequest().getInputStream();
       
       
        Source<ByteString, NotUsed> src1 = Source.unfoldResourceAsync(
                () -> FutureConverters.toJava(Futures.successful(new MyReadListener(servletInputStream))),
                n -> FutureConverters.toJava(n.cs().future()),
                n -> {
                    return FutureConverters.toJava(Futures.successful(Done.getInstance()));
                });

Now, how I can convert the stream of ByteString in a InputStream parseable by Commons FileUpload Library?

Thanks in advance

Stefano