beacon-chain-java icon indicating copy to clipboard operation
beacon-chain-java copied to clipboard

Rethink NettyServer.channelsStream implementation

Open ericsson49 opened this issue 6 years ago • 0 comments

NettyServer uses UnicastProcessor as a publisher of incoming connections. Thus it supports one subscriber only. This is a problem, if one wants to implement beaconchain_peers metric, for example. As a part of metrics implementation (#178), I temporarily attached ReplayProcessor to UnicastProcessor, and used former as channels stream (by analogy to ConnectionManager client connections stream). While it's working, the implementation should be rewised.

ericsson49 avatar Sep 04 '19 09:09 ericsson49