Package net.minecraft.util.io.netty.channel

Examples of net.minecraft.util.io.netty.channel.Channel.pipeline()

131
132
133
134
135
136
137
138
139
140
141
          @Override
          public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                Channel channel = (Channel) msg;

                // Prepare to initialize ths channel
                channel.pipeline().addFirst(beginInitProtocol);
                ctx.fireChannelRead(msg);
          }
        };
  }
 
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
       
        // Channel future that contains the server connection
        Channel serverChannel = ((ChannelFuture)item).channel();
 
        serverChannels.add(serverChannel);
        serverChannel.pipeline().addFirst(serverChannelHandler);
        looking = false;
      }
    }
  }
 
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
              @Override
              public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                    Channel channel = (Channel) msg;

                    // Prepare to initialize ths channel
                    channel.pipeline().addFirst(beginInitProtocol);
                    ctx.fireChannelRead(msg);
              }
            };
           
            // Get the current NetworkMananger list
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
   
    // For thread safety - see ChannelInjector.close()
    channel.eventLoop().submit(new Callable<Object>() {
      @Override
      public Object call() throws Exception {
        channel.pipeline().remove(handler);
        return null;
      }
    });
  }
 
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
            channel = (Channel) this.getChannelField().get(this.getNetworkManager(player));
        } catch (final Exception e) {
            e.printStackTrace();
            return null;
        }
        return channel.pipeline();
    }

    @Override
    protected void hookPlayer(Player player) {
        final ChannelPipeline pipeline = this.getPipeline(player);
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
    public static void bind(Player player) {
      Object entityPlayer = Conversion.toEntityHandle.convert(player);
      Object playerConnection = EntityPlayerRef.playerConnection.get(entityPlayer);
      Object networkManager = PlayerConnectionRef.networkManager.get(playerConnection);
      Channel channel = NetworkManagerRef.channel.get(networkManager);
      channel.pipeline().addBefore("packet_handler", "bkcommonlib", new CommonChannelListener(player));
    }
   
    public static void unbind(Player player) {
      Object entityPlayer = Conversion.toEntityHandle.convert(player);
      Object playerConnection = EntityPlayerRef.playerConnection.get(entityPlayer);
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
      final Channel channel = NetworkManagerRef.channel.get(networkManager);
      channel.eventLoop().submit(new Callable<Object>() {

        @Override
        public Object call() throws Exception {
          channel.pipeline().remove("bkcommonlib");
          return null;
        }
      });
    }
   
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.