Skip to content

Commit

Permalink
Rename streaming messages (#314)
Browse files Browse the repository at this point in the history
* Rename HttpRequest to LiveHttpRequest.

* Rename HttpResponse to LiveHttpResponse.

* Rename StreamingHttpMessage to LiveHttpMessage.

* Rename FullHttpRequest to HttpRequest.

* Rename FullHttpResponse to HttpResponse.

* Rename FullHttpMessage to HttpMessage.

* Rename conversion methods between HTTP message types:
- toStreamingResponse() to stream()
- toFullResponse() to aggregate()
  • Loading branch information
mikkokar committed Oct 18, 2018
1 parent c8b581f commit d138473
Show file tree
Hide file tree
Showing 263 changed files with 2,893 additions and 2,889 deletions.
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

0 comments on commit d138473

Please sign in to comment.