Package org.drasyl.peer.connection

Class PeerChannelGroup

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractSet<io.netty.channel.Channel>

io.netty.channel.group.DefaultChannelGroup

org.drasyl.peer.connection.PeerChannelGroup

All Implemented Interfaces:

io.netty.channel.group.ChannelGroup, Comparable<io.netty.channel.group.ChannelGroup>, Iterable<io.netty.channel.Channel>, Collection<io.netty.channel.Channel>, Set<io.netty.channel.Channel>

public class PeerChannelGroup
extends io.netty.channel.group.DefaultChannelGroup

Special type of ChannelGroup, which has a lookup complexity of O(1) instead of O(n) for lookups by CompressedPublicKey.

Constructor Summary

Constructors

Constructor	Description
PeerChannelGroup(int networkId, Identity identity)
PeerChannelGroup(int networkId, Identity identity, io.netty.util.concurrent.EventExecutor executor)

Method Summary

Modifier and Type	Method	Description
boolean	add(io.netty.channel.Channel channel)
boolean	add(CompressedPublicKey publicKey, io.netty.channel.Channel channel)
boolean	equals(Object o)
io.netty.channel.Channel	find(CompressedPublicKey publicKey)	Searches the channel for given public key.
int	hashCode()
boolean	remove(Object o)
io.netty.util.concurrent.Future<Void>	writeAndFlush(CompressedPublicKey publicKey, Object message)

Methods inherited from class io.netty.channel.group.DefaultChannelGroup

clear, close, close, compareTo, contains, deregister, deregister, disconnect, disconnect, find, flush, flush, flushAndWrite, flushAndWrite, isEmpty, iterator, name, newCloseFuture, newCloseFuture, size, toArray, toArray, toString, write, write, write, writeAndFlush, writeAndFlush, writeAndFlush

Methods inherited from class java.util.AbstractSet

removeAll

Methods inherited from class java.util.AbstractCollection

addAll, containsAll, retainAll

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Set

addAll, containsAll, removeAll, retainAll, spliterator

Constructor Details

PeerChannelGroup

public PeerChannelGroup(int networkId,
 Identity identity)

PeerChannelGroup

public PeerChannelGroup(int networkId,
 Identity identity,
 io.netty.util.concurrent.EventExecutor executor)

Method Details

writeAndFlush

public io.netty.util.concurrent.Future<Void> writeAndFlush(CompressedPublicKey publicKey,
 Object message)

Parameters:

publicKey - the recipient of a message as compressed public key

message - the message to send

Returns:

a completed future if the message was successfully processed, otherwise an exceptionally future

find

public io.netty.channel.Channel find(CompressedPublicKey publicKey)

Searches the channel for given public key.

Parameters:

publicKey - public key for which a channel should be searched

Returns:

the channel if found, otherwise null

add

public boolean add(io.netty.channel.Channel channel)

Specified by:

add in interface Collection<io.netty.channel.Channel>

Specified by:

add in interface Set<io.netty.channel.Channel>

Overrides:

add in class io.netty.channel.group.DefaultChannelGroup

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<io.netty.channel.Channel>

Specified by:

remove in interface Set<io.netty.channel.Channel>

Overrides:

remove in class io.netty.channel.group.DefaultChannelGroup

hashCode

public int hashCode()

Specified by:

hashCode in interface Collection<io.netty.channel.Channel>

Specified by:

hashCode in interface Set<io.netty.channel.Channel>

Overrides:

hashCode in class io.netty.channel.group.DefaultChannelGroup

equals

public boolean equals(Object o)

Specified by:

equals in interface Collection<io.netty.channel.Channel>

Specified by:

equals in interface Set<io.netty.channel.Channel>

Overrides:

equals in class io.netty.channel.group.DefaultChannelGroup

add

public boolean add(CompressedPublicKey publicKey,
 io.netty.channel.Channel channel)