Class PeerService

Inheritance
System.Object
SocketBase
UdpServer
PeerService
Implements
System.IDisposable
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Catalyst.Core.Lib.P2P
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class PeerService : UdpServer, IUdpServer, IPeerService, IObservableMessageStreamer<ProtocolMessage>, ISocket, IDisposable

Constructors

| Improve this Doc View Source

PeerService(IUdpServerEventLoopGroupFactory, IUdpServerChannelFactory, IPeerDiscovery, IEnumerable<IP2PMessageObserver>, IPeerSettings, ILogger, IHealthChecker)

Declaration
public PeerService(IUdpServerEventLoopGroupFactory udpServerEventLoopGroupFactory, IUdpServerChannelFactory serverChannelFactory, IPeerDiscovery peerDiscovery, IEnumerable<IP2PMessageObserver> messageHandlers, IPeerSettings peerSettings, ILogger logger, IHealthChecker healthChecker)
Parameters
Type Name Description
IUdpServerEventLoopGroupFactory udpServerEventLoopGroupFactory
IUdpServerChannelFactory serverChannelFactory
IPeerDiscovery peerDiscovery
System.Collections.Generic.IEnumerable<IP2PMessageObserver> messageHandlers
IPeerSettings peerSettings
ILogger logger
IHealthChecker healthChecker

Properties

| Improve this Doc View Source

Discovery

Declaration
public IPeerDiscovery Discovery { get; }
Property Value
Type Description
IPeerDiscovery
| Improve this Doc View Source

MessageStream

Declaration
public IObservable<IObserverDto<ProtocolMessage>> MessageStream { get; }
Property Value
Type Description
System.IObservable<IObserverDto<ProtocolMessage>>

Methods

| Improve this Doc View Source

StartAsync()

Declaration
public override Task StartAsync()
Returns
Type Description
System.Threading.Tasks.Task
Overrides

Implements

System.IDisposable