replaced broken < with < and same for gt
This commit is contained in:
parent
e7ad9fed77
commit
ae4017e76a
@ -62,7 +62,7 @@ import java.util.concurrent.TimeUnit;
|
|||||||
* // for 30 seconds. The connection is closed when there is no inbound traffic
|
* // for 30 seconds. The connection is closed when there is no inbound traffic
|
||||||
* // for 60 seconds.
|
* // for 60 seconds.
|
||||||
*
|
*
|
||||||
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
||||||
* {@code @Override}
|
* {@code @Override}
|
||||||
* public void initChannel({@link Channel} channel) {
|
* public void initChannel({@link Channel} channel) {
|
||||||
* channel.pipeline().addLast("idleStateHandler", new {@link IdleStateHandler}(60, 30, 0));
|
* channel.pipeline().addLast("idleStateHandler", new {@link IdleStateHandler}(60, 30, 0));
|
||||||
|
@ -33,7 +33,7 @@ import java.util.concurrent.TimeUnit;
|
|||||||
* // The connection is closed when there is no inbound traffic
|
* // The connection is closed when there is no inbound traffic
|
||||||
* // for 30 seconds.
|
* // for 30 seconds.
|
||||||
*
|
*
|
||||||
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
||||||
* public void initChannel({@link Channel} channel) {
|
* public void initChannel({@link Channel} channel) {
|
||||||
* channel.pipeline().addLast("readTimeoutHandler", new {@link ReadTimeoutHandler}(30);
|
* channel.pipeline().addLast("readTimeoutHandler", new {@link ReadTimeoutHandler}(30);
|
||||||
* channel.pipeline().addLast("myHandler", new MyHandler());
|
* channel.pipeline().addLast("myHandler", new MyHandler());
|
||||||
|
@ -36,7 +36,7 @@ import java.util.concurrent.TimeUnit;
|
|||||||
* // The connection is closed when there is no outbound traffic
|
* // The connection is closed when there is no outbound traffic
|
||||||
* // for 30 seconds.
|
* // for 30 seconds.
|
||||||
*
|
*
|
||||||
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
* public class MyChannelInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
||||||
* public void initChannel({@link Channel} channel) {
|
* public void initChannel({@link Channel} channel) {
|
||||||
* channel.pipeline().addLast("writeTimeoutHandler", new {@link WriteTimeoutHandler}(30);
|
* channel.pipeline().addLast("writeTimeoutHandler", new {@link WriteTimeoutHandler}(30);
|
||||||
* channel.pipeline().addLast("myHandler", new MyHandler());
|
* channel.pipeline().addLast("myHandler", new MyHandler());
|
||||||
|
@ -92,7 +92,7 @@ import java.lang.annotation.Target;
|
|||||||
* <pre>
|
* <pre>
|
||||||
* // Create a new handler instance per channel.
|
* // Create a new handler instance per channel.
|
||||||
* // See {@link ChannelInitializer#initChannel(Channel)}.
|
* // See {@link ChannelInitializer#initChannel(Channel)}.
|
||||||
* public class DataServerInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
* public class DataServerInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
||||||
* {@code @Override}
|
* {@code @Override}
|
||||||
* public void initChannel({@link Channel} channel) {
|
* public void initChannel({@link Channel} channel) {
|
||||||
* channel.pipeline().addLast("handler", <b>new DataServerHandler()</b>);
|
* channel.pipeline().addLast("handler", <b>new DataServerHandler()</b>);
|
||||||
@ -114,12 +114,12 @@ import java.lang.annotation.Target;
|
|||||||
*
|
*
|
||||||
* {@code @Sharable}
|
* {@code @Sharable}
|
||||||
* public class DataServerHandler extends {@link SimpleChannelInboundHandler}<Message> {
|
* public class DataServerHandler extends {@link SimpleChannelInboundHandler}<Message> {
|
||||||
* private final {@link AttributeKey}<{@link Boolean}> auth =
|
* private final {@link AttributeKey}<{@link Boolean}> auth =
|
||||||
* {@link AttributeKey#valueOf(String) AttributeKey.valueOf("auth")};
|
* {@link AttributeKey#valueOf(String) AttributeKey.valueOf("auth")};
|
||||||
*
|
*
|
||||||
* {@code @Override}
|
* {@code @Override}
|
||||||
* public void channelRead({@link ChannelHandlerContext} ctx, Message message) {
|
* public void channelRead({@link ChannelHandlerContext} ctx, Message message) {
|
||||||
* {@link Attribute}<{@link Boolean}> attr = ctx.attr(auth);
|
* {@link Attribute}<{@link Boolean}> attr = ctx.attr(auth);
|
||||||
* {@link Channel} ch = ctx.channel();
|
* {@link Channel} ch = ctx.channel();
|
||||||
* if (message instanceof LoginMessage) {
|
* if (message instanceof LoginMessage) {
|
||||||
* authenticate((LoginMessage) o);
|
* authenticate((LoginMessage) o);
|
||||||
@ -138,7 +138,7 @@ import java.lang.annotation.Target;
|
|||||||
* Now that the state of the handler isattached to the {@link ChannelHandlerContext}, you can add the
|
* Now that the state of the handler isattached to the {@link ChannelHandlerContext}, you can add the
|
||||||
* same handler instance to different pipelines:
|
* same handler instance to different pipelines:
|
||||||
* <pre>
|
* <pre>
|
||||||
* public class DataServerInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
* public class DataServerInitializer extends {@link ChannelInitializer}<{@link Channel}> {
|
||||||
*
|
*
|
||||||
* private static final DataServerHandler <b>SHARED</b> = new DataServerHandler();
|
* private static final DataServerHandler <b>SHARED</b> = new DataServerHandler();
|
||||||
*
|
*
|
||||||
|
@ -87,14 +87,14 @@ import java.nio.channels.Channels;
|
|||||||
* <pre>
|
* <pre>
|
||||||
* public class FactorialHandler extends {@link ChannelInboundHandlerAdapter}<{@link Integer}> {
|
* public class FactorialHandler extends {@link ChannelInboundHandlerAdapter}<{@link Integer}> {
|
||||||
*
|
*
|
||||||
* private final {@link AttributeKey}<{@link Integer}> counter =
|
* private final {@link AttributeKey}<{@link Integer}> counter =
|
||||||
* new {@link AttributeKey}<{@link Integer}>("counter");
|
* new {@link AttributeKey}<{@link Integer}>("counter");
|
||||||
*
|
*
|
||||||
* // This handler will receive a sequence of increasing integers starting
|
* // This handler will receive a sequence of increasing integers starting
|
||||||
* // from 1.
|
* // from 1.
|
||||||
* {@code @Override}
|
* {@code @Override}
|
||||||
* public void channelRead({@link ChannelHandlerContext} ctx, {@link Integer} integer) {
|
* public void channelRead({@link ChannelHandlerContext} ctx, {@link Integer} integer) {
|
||||||
* {@link Attribute}<{@link Integer}> attr = ctx.getAttr(counter);
|
* {@link Attribute}<{@link Integer}> attr = ctx.getAttr(counter);
|
||||||
* Integer a = ctx.getAttr(counter).get();
|
* Integer a = ctx.getAttr(counter).get();
|
||||||
*
|
*
|
||||||
* if (a == null) {
|
* if (a == null) {
|
||||||
|
Loading…
Reference in New Issue
Block a user