org.cloudburstmc.netty.channel.proxy

Class ProxyChannel<T extends io.netty.channel.Channel>

java.lang.Object

org.cloudburstmc.netty.channel.proxy.ProxyChannel<T>

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

Direct Known Subclasses:

RakClientChannel, RakServerChannel

public abstract class ProxyChannel<T extends io.netty.channel.Channel>
extends Object
implements io.netty.channel.Channel

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.Channel

io.netty.channel.Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field and Description
protected T	channel TODO: consider config mixing with parent
protected io.netty.channel.ChannelPipeline	pipeline

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ProxyChannel(T parent)

Method Summary

Modifier and Type	Method and Description
io.netty.buffer.ByteBufAllocator	alloc()
<U> io.netty.util.Attribute<U>	attr(io.netty.util.AttributeKey<U> key)
io.netty.channel.ChannelFuture	bind(SocketAddress localAddress)
io.netty.channel.ChannelFuture	bind(SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
long	bytesBeforeUnwritable()
long	bytesBeforeWritable()
io.netty.channel.ChannelFuture	close()
io.netty.channel.ChannelFuture	close(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	closeFuture()
int	compareTo(io.netty.channel.Channel o)
io.netty.channel.ChannelConfig	config()
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress)
io.netty.channel.ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelPromise	correctPromise(io.netty.channel.ChannelPromise remotePromise)
io.netty.channel.ChannelFuture	deregister()
io.netty.channel.ChannelFuture	deregister(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	disconnect()
io.netty.channel.ChannelFuture	disconnect(io.netty.channel.ChannelPromise promise)
io.netty.channel.EventLoop	eventLoop()
io.netty.channel.Channel	flush()
<U> boolean	hasAttr(io.netty.util.AttributeKey<U> key)
io.netty.channel.ChannelId	id()
protected io.netty.channel.ChannelPipeline	internalPipeline()
boolean	isActive()
boolean	isOpen()
boolean	isRegistered()
boolean	isWritable()
InetSocketAddress	localAddress()
io.netty.channel.ChannelMetadata	metadata()
protected io.netty.channel.DefaultChannelPipeline	newChannelPipeline()
io.netty.channel.ChannelFuture	newFailedFuture(Throwable cause)
io.netty.channel.ChannelProgressivePromise	newProgressivePromise()
io.netty.channel.ChannelPromise	newPromise()
io.netty.channel.ChannelFuture	newSucceededFuture()
void	onCloseTriggered(io.netty.channel.ChannelPromise promise)
io.netty.channel.Channel	parent()
io.netty.channel.ChannelPipeline	pipeline()
io.netty.channel.Channel	read()
InetSocketAddress	remoteAddress()
io.netty.channel.Channel.Unsafe	unsafe()
io.netty.channel.ChannelPromise	voidPromise()
io.netty.channel.ChannelFuture	write(Object msg)
io.netty.channel.ChannelFuture	write(Object msg, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg)
io.netty.channel.ChannelFuture	writeAndFlush(Object msg, io.netty.channel.ChannelPromise promise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

channel

protected final T extends io.netty.channel.Channel channel

TODO: consider config mixing with parent

pipeline

protected final io.netty.channel.ChannelPipeline pipeline

Constructor Detail

ProxyChannel

protected ProxyChannel(T parent)

Method Detail

onCloseTriggered

public void onCloseTriggered(io.netty.channel.ChannelPromise promise)

correctPromise

public io.netty.channel.ChannelPromise correctPromise(io.netty.channel.ChannelPromise remotePromise)

newChannelPipeline

protected io.netty.channel.DefaultChannelPipeline newChannelPipeline()

internalPipeline

protected final io.netty.channel.ChannelPipeline internalPipeline()

id

public io.netty.channel.ChannelId id()

Specified by:

id in interface io.netty.channel.Channel

eventLoop

public io.netty.channel.EventLoop eventLoop()

Specified by:

eventLoop in interface io.netty.channel.Channel

parent

public io.netty.channel.Channel parent()

Specified by:

parent in interface io.netty.channel.Channel

config

public io.netty.channel.ChannelConfig config()

Specified by:

config in interface io.netty.channel.Channel

isOpen

public boolean isOpen()

Specified by:

isOpen in interface io.netty.channel.Channel

isRegistered

public boolean isRegistered()

Specified by:

isRegistered in interface io.netty.channel.Channel

isActive

public boolean isActive()

Specified by:

isActive in interface io.netty.channel.Channel

metadata

public io.netty.channel.ChannelMetadata metadata()

Specified by:

metadata in interface io.netty.channel.Channel

localAddress

public InetSocketAddress localAddress()

Specified by:

localAddress in interface io.netty.channel.Channel

remoteAddress

public InetSocketAddress remoteAddress()

Specified by:

remoteAddress in interface io.netty.channel.Channel

closeFuture

public io.netty.channel.ChannelFuture closeFuture()

Specified by:

closeFuture in interface io.netty.channel.Channel

isWritable

public boolean isWritable()

Specified by:

isWritable in interface io.netty.channel.Channel

bytesBeforeUnwritable

public long bytesBeforeUnwritable()

Specified by:

bytesBeforeUnwritable in interface io.netty.channel.Channel

bytesBeforeWritable

public long bytesBeforeWritable()

Specified by:

bytesBeforeWritable in interface io.netty.channel.Channel

unsafe

public io.netty.channel.Channel.Unsafe unsafe()

Specified by:

unsafe in interface io.netty.channel.Channel

pipeline

public io.netty.channel.ChannelPipeline pipeline()

Specified by:

pipeline in interface io.netty.channel.Channel

alloc

public io.netty.buffer.ByteBufAllocator alloc()

Specified by:

alloc in interface io.netty.channel.Channel

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress)

Specified by:

bind in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              SocketAddress localAddress)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

disconnect

public io.netty.channel.ChannelFuture disconnect()

Specified by:

disconnect in interface io.netty.channel.ChannelOutboundInvoker

close

public io.netty.channel.ChannelFuture close()

Specified by:

close in interface io.netty.channel.ChannelOutboundInvoker

deregister

public io.netty.channel.ChannelFuture deregister()

Specified by:

deregister in interface io.netty.channel.ChannelOutboundInvoker

bind

public io.netty.channel.ChannelFuture bind(SocketAddress localAddress,
                                           io.netty.channel.ChannelPromise promise)

Specified by:

bind in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              io.netty.channel.ChannelPromise promise)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

connect

public io.netty.channel.ChannelFuture connect(SocketAddress remoteAddress,
                                              SocketAddress localAddress,
                                              io.netty.channel.ChannelPromise promise)

Specified by:

connect in interface io.netty.channel.ChannelOutboundInvoker

disconnect

public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise promise)

Specified by:

disconnect in interface io.netty.channel.ChannelOutboundInvoker

close

public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise promise)

Specified by:

close in interface io.netty.channel.ChannelOutboundInvoker

deregister

public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise promise)

Specified by:

deregister in interface io.netty.channel.ChannelOutboundInvoker

read

public io.netty.channel.Channel read()

Specified by:

read in interface io.netty.channel.Channel

Specified by:

read in interface io.netty.channel.ChannelOutboundInvoker

write

public io.netty.channel.ChannelFuture write(Object msg)

Specified by:

write in interface io.netty.channel.ChannelOutboundInvoker

write

public io.netty.channel.ChannelFuture write(Object msg,
                                            io.netty.channel.ChannelPromise promise)

Specified by:

write in interface io.netty.channel.ChannelOutboundInvoker

flush

public io.netty.channel.Channel flush()

Specified by:

flush in interface io.netty.channel.Channel

Specified by:

flush in interface io.netty.channel.ChannelOutboundInvoker

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg,
                                                    io.netty.channel.ChannelPromise promise)

Specified by:

writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker

writeAndFlush

public io.netty.channel.ChannelFuture writeAndFlush(Object msg)

Specified by:

writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker

newPromise

public io.netty.channel.ChannelPromise newPromise()

Specified by:

newPromise in interface io.netty.channel.ChannelOutboundInvoker

newProgressivePromise

public io.netty.channel.ChannelProgressivePromise newProgressivePromise()

Specified by:

newProgressivePromise in interface io.netty.channel.ChannelOutboundInvoker

newSucceededFuture

public io.netty.channel.ChannelFuture newSucceededFuture()

Specified by:

newSucceededFuture in interface io.netty.channel.ChannelOutboundInvoker

newFailedFuture

public io.netty.channel.ChannelFuture newFailedFuture(Throwable cause)

Specified by:

newFailedFuture in interface io.netty.channel.ChannelOutboundInvoker

voidPromise

public io.netty.channel.ChannelPromise voidPromise()

Specified by:

voidPromise in interface io.netty.channel.ChannelOutboundInvoker

attr

public <U> io.netty.util.Attribute<U> attr(io.netty.util.AttributeKey<U> key)

Specified by:

attr in interface io.netty.util.AttributeMap

hasAttr

public <U> boolean hasAttr(io.netty.util.AttributeKey<U> key)

Specified by:

hasAttr in interface io.netty.util.AttributeMap

compareTo

public int compareTo(io.netty.channel.Channel o)

Specified by:

compareTo in interface Comparable<io.netty.channel.Channel>