add Player interface
This commit is contained in:
12
src/main/java/mc/core/NetChannel.java
Normal file
12
src/main/java/mc/core/NetChannel.java
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
/*
|
||||||
|
* DmitriyMX <dimon550@gmail.com>
|
||||||
|
* 2018-04-13
|
||||||
|
*/
|
||||||
|
package mc.core;
|
||||||
|
|
||||||
|
public interface NetChannel {
|
||||||
|
void write(Object obj);
|
||||||
|
void flush();
|
||||||
|
void writeAndFlush(Object obj);
|
||||||
|
|
||||||
|
}
|
||||||
14
src/main/java/mc/core/Player.java
Normal file
14
src/main/java/mc/core/Player.java
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
/*
|
||||||
|
* DmitriyMX <dimon550@gmail.com>
|
||||||
|
* 2018-04-13
|
||||||
|
*/
|
||||||
|
package mc.core;
|
||||||
|
|
||||||
|
import java.net.InetAddress;
|
||||||
|
|
||||||
|
public interface Player {
|
||||||
|
int getId();
|
||||||
|
String getName();
|
||||||
|
InetAddress getAddress();
|
||||||
|
NetChannel getChannel();
|
||||||
|
}
|
||||||
@@ -10,6 +10,7 @@ import io.netty.handler.codec.ByteToMessageDecoder;
|
|||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import mc.core.CSPacket;
|
import mc.core.CSPacket;
|
||||||
import mc.core.NetStream;
|
import mc.core.NetStream;
|
||||||
|
import mc.core.netty.proto_125.wrappers.WrapperNetStream;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,29 @@
|
|||||||
|
/*
|
||||||
|
* DmitriyMX <dimon550@gmail.com>
|
||||||
|
* 2018-04-13
|
||||||
|
*/
|
||||||
|
package mc.core.netty.proto_125.wrappers;
|
||||||
|
|
||||||
|
import io.netty.channel.Channel;
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import mc.core.NetChannel;
|
||||||
|
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class WrapperNetChannel implements NetChannel {
|
||||||
|
private final Channel channel;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void write(Object obj) {
|
||||||
|
channel.write(obj);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void flush() {
|
||||||
|
channel.flush();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void writeAndFlush(Object obj) {
|
||||||
|
channel.writeAndFlush(obj);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -2,7 +2,7 @@
|
|||||||
* DmitriyMX <dimon550@gmail.com>
|
* DmitriyMX <dimon550@gmail.com>
|
||||||
* 2018-04-08
|
* 2018-04-08
|
||||||
*/
|
*/
|
||||||
package mc.core.netty.proto_125;
|
package mc.core.netty.proto_125.wrappers;
|
||||||
|
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
Reference in New Issue
Block a user