package org.jboss.resteasy.plugins.providers.multipart;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.ext.RuntimeDelegate;
import org.jboss.resteasy.spi.AsyncOutputStream;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
public class extends AsyncOutputStream {
private MultivaluedMap<String, Object> ;
private AsyncOutputStream ;
private boolean = false;
public (final MultivaluedMap<String, Object> headers,
final AsyncOutputStream delegate) {
this.headers = headers;
this.stream = delegate;
}
@SuppressWarnings(value = "unchecked")
protected CompletionStage<Void> () {
CompletionStage<Void> ret = CompletableFuture.completedFuture(null);
if (headersFlushed)
return ret;
headersFlushed = true;
RuntimeDelegate delegate = RuntimeDelegate.getInstance();
for (String key : headers.keySet()) {
for (Object obj : headers.get(key)) {
String value;
RuntimeDelegate.HeaderDelegate headerDelegate = delegate
.createHeaderDelegate(obj.getClass());
if (headerDelegate != null) {
value = headerDelegate.toString(obj);
} else {
value = obj.toString();
}
ret = ret.thenCompose(v -> stream.asyncWrite(key.getBytes(StandardCharsets.US_ASCII)))
.thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.COLON_SPACE_BYTES))
.thenCompose(v -> stream.asyncWrite(value.getBytes(StandardCharsets.US_ASCII)))
.thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.LINE_SEPARATOR_BYTES));
}
}
return ret.thenCompose(v -> stream.asyncWrite(AbstractMultipartWriter.LINE_SEPARATOR_BYTES));
}
@Override
public void (int i) throws IOException {
flushHeaders();
stream.write(i);
}
@Override
public void (byte[] bytes) throws IOException {
flushHeaders();
stream.write(bytes);
}
@Override
public void (byte[] bytes, int i, int i1) throws IOException {
flushHeaders();
stream.write(bytes, i, i1);
}
@Override
public void () throws IOException {
stream.flush();
}
@Override
public void () throws IOException {
stream.close();
}
@Override
public CompletionStage<Void> () {
return stream.asyncFlush();
}
@Override
public CompletionStage<Void> (byte[] bytes, int offset, int length) {
return flushHeaders()
.thenCompose(v -> stream.asyncWrite(bytes, offset, length));
}
}