Skip to content
Permalink
Browse files

Remove a couple of comments and an unused file.

  • Loading branch information...
jtownson committed May 16, 2019
1 parent 5ec0852 commit 1fa1d12c89bd473ec575d0da244267d8262264a5

This file was deleted.

Oops, something went wrong.
@@ -30,8 +30,6 @@ class TCPPeerGroup[M](val config: Config)(implicit scheduler: Scheduler, codec:

private val channelSubject = PublishSubject[Channel[InetMultiAddress, M]]()

// new Subscribers[Channel[InetMultiAddress, M]](s"Channel Subscribers for TCPPeerGroup@'$processAddress'")

private val workerGroup = new NioEventLoopGroup()

private val clientBootstrap = new Bootstrap()
@@ -93,14 +91,12 @@ object TCPPeerGroup {
) extends Channel[InetMultiAddress, M] {

private val log = LoggerFactory.getLogger(getClass)
private val messageSubject = ReplaySubject[M]()

log.debug(
s"Creating server channel from ${nettyChannel.localAddress()} to ${nettyChannel.remoteAddress()} with channel id ${nettyChannel.id}"
)

private val messageSubject = ReplaySubject[M]()
//new Subscribers[M](s"Subscribers for ServerChannelImpl@${nettyChannel.id}")

nettyChannel
.pipeline()
.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(Int.MaxValue, 0, 4, 0, 4))

0 comments on commit 1fa1d12

Please sign in to comment.
You can’t perform that action at this time.