Skip to content

Commit

Permalink
Made listener.transport.Request implementations public.
Browse files Browse the repository at this point in the history
  • Loading branch information
Robin Duda committed Mar 28, 2018
1 parent 45e82e8 commit ce2c33b
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ public void stop(Future<Void> stop) {
}

private void packet(RoutingContext context) {
processor.submit(() -> new RestRequest(context, settings.get(), context.request()));
processor.submit(() -> new RestRequest(context, settings.get()));
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,15 +17,15 @@
* <p>
* HTTP/REST request object.
*/
class RestRequest implements Request {
public class RestRequest implements Request {
private HttpServerRequest request;
private JsonObject data = new JsonObject();
private ListenerSettings settings;
private int size;

RestRequest(RoutingContext context, ListenerSettings settings, HttpServerRequest request) {
public RestRequest(RoutingContext context, ListenerSettings settings) {
this.size = context.getBody().length();
this.request = request;
this.request = context.request();
this.settings = settings;

parseData(context);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,13 +10,13 @@
* <p>
* TCP request implementation.
*/
class TcpRequest implements Request {
public class TcpRequest implements Request {
private Connection connection;
private ListenerSettings settings;
private JsonObject data;
private int size;

TcpRequest(Connection connection, Buffer buffer, ListenerSettings settings) {
public TcpRequest(Connection connection, Buffer buffer, ListenerSettings settings) {
this.size = buffer.length();
this.connection = connection;
this.settings = settings;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@
* <p>
* UDP request object.
*/
class UdpRequest implements Request {
public class UdpRequest implements Request {
private int size;
private DatagramPacket packet;
private CoreContext context;
private ListenerSettings settings;
private JsonObject data;

UdpRequest(CoreContext context, ListenerSettings settings, DatagramPacket packet) {
public UdpRequest(CoreContext context, ListenerSettings settings, DatagramPacket packet) {
this.size = packet.data().length();
this.context = context;
this.settings = settings;
Expand Down

0 comments on commit ce2c33b

Please sign in to comment.