Skip to content

Commit ad87bd1

Browse files
committed
Rename Discard singleton
1 parent acc2eb9 commit ad87bd1

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

client/src/main/java/org/asynchttpclient/netty/DiscardEvent.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,5 @@
1717
* Simple marker for stopping publishing bytes
1818
*/
1919
public enum DiscardEvent {
20-
INSTANCE
20+
DISCARD
2121
}

client/src/main/java/org/asynchttpclient/netty/channel/Channels.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public static void setAttribute(Channel channel, Object o) {
4040
}
4141

4242
public static void setDiscard(Channel channel) {
43-
setAttribute(channel, DiscardEvent.INSTANCE);
43+
setAttribute(channel, DiscardEvent.DISCARD);
4444
}
4545

4646
public static boolean isChannelValid(Channel channel) {

client/src/main/java/org/asynchttpclient/netty/handler/AsyncHttpClientHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public void channelRead(final ChannelHandlerContext ctx, Object msg) throws Exce
102102
ctx.pipeline().remove(publisher);
103103
Channels.setDiscard(channel);
104104
}
105-
} else if (attribute != DiscardEvent.INSTANCE) {
105+
} else if (attribute != DiscardEvent.DISCARD) {
106106
// unhandled message
107107
logger.debug("Orphan channel {} with attribute {} received message {}, closing", channel, attribute, msg);
108108
Channels.silentlyCloseChannel(channel);

0 commit comments

Comments
 (0)