Streaming use-case using netty-http

StreamingRequests.java

 // BodyConsumer abstract-class is used to handle large files,
  // we can handle the chunks as we receive it
  // and handle clean up when we are done in the finished methodi
  @Path("/upload")
  @PUT
  public BodyConsumer streamUploadFile(HttpRequest request, HttpResponder responder) throws FileNotFoundException {
    final File file = new File(request.getHeader("File-Path"));
    final FileChannel fileChannel = new FileOutputStream(file).getChannel();

    return new BodyConsumer() {
      @Override
      public void chunk(ChannelBuffer request, HttpResponder responder) {
        try {
          // write the incoming chunks
          fileChannel.write(request.toByteBuffer());
        } catch (IOException e) {
          throw Throwables.propagate(e);
        }
      }

      @Override
      public void finished(HttpResponder responder) {
        try {
          fileChannel.close();
          // Upload is finished. Respond with success.
          responder.sendStatus(HttpResponseStatus.OK);
        } catch (IOException e) {
          // handle exception
        }
      }

      @Override
      public void handleError(Throwable cause) {
        Closeables.closeQuietly(fileChannel);
        // delete the file since the upload failed on error.
        file.delete();
      }
    };
  }