Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Rename streaming messages #314

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@
* more data than expected.
* <p>
* A streaming HTTP message can be aggregated to a full message.
* The aggregator methods {@link HttpRequest#toFullRequest}, and
* {@link HttpResponse#toFullResponse} consume data from a network socket or
* The aggregator methods {@link LiveHttpRequest#aggregate}, and
* {@link LiveHttpResponse#aggregate} consume data from a network socket or
* some other unpredictable source and emit this exception when more data is
* received than expected.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
import static java.util.stream.Collectors.toMap;

/**
* Provides a representation of Form Url Encoded parameters extracted from an {@link HttpRequest}.
* Provides a representation of Form Url Encoded parameters extracted from an {@link LiveHttpRequest}.
*/
public final class FormData {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
package com.hotels.styx.api;

/**
* Handles an {@link HttpRequest}, returning an {@link Eventual} that is expected to publish a single {@link HttpResponse} value.
* Handles an {@link LiveHttpRequest}, returning an {@link Eventual} that is expected to publish a single {@link LiveHttpResponse} value.
*/
@FunctionalInterface
public interface HttpHandler {
Expand All @@ -26,5 +26,5 @@ public interface HttpHandler {
* @param request the current incoming request
* @return an {@link Eventual} that is expected to publish a single response
*/
Eventual<HttpResponse> handle(HttpRequest request, HttpInterceptor.Context context);
Eventual<LiveHttpResponse> handle(LiveHttpRequest request, HttpInterceptor.Context context);
}
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ default Context context() {
* @param request request to propagate
* @return observable that will provide the response
*/
Eventual<HttpResponse> proceed(HttpRequest request);
Eventual<LiveHttpResponse> proceed(LiveHttpRequest request);

}

Expand All @@ -99,6 +99,6 @@ default Context context() {
* @param chain chain
* @return observable that will provide the response
*/
Eventual<HttpResponse> intercept(HttpRequest request, Chain chain);
Eventual<LiveHttpResponse> intercept(LiveHttpRequest request, Chain chain);

}
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
/**
* All behaviour common to both full requests and full responses.
*/
interface FullHttpMessage {
interface HttpMessage {
/**
* Returns the protocol version of this.
*
Expand Down