Class ReputationManager

Inheritance
System.Object
ReputationManager
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.ReputationSystem
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class ReputationManager : IReputationManager, IDisposable

Constructors

| Improve this Doc View Source

ReputationManager(IPeerRepository, ILogger)

Declaration
public ReputationManager(IPeerRepository peerRepository, ILogger logger)
Parameters
Type Name Description
IPeerRepository peerRepository
ILogger logger

Fields

| Improve this Doc View Source

ReputationEvent

Declaration
public readonly ReplaySubject<IPeerReputationChange> ReputationEvent
Field Value
Type Description
ReplaySubject<IPeerReputationChange>

Properties

| Improve this Doc View Source

MergedEventStream

Declaration
public IObservable<IPeerReputationChange> MergedEventStream { get; set; }
Property Value
Type Description
System.IObservable<IPeerReputationChange>
| Improve this Doc View Source

PeerRepository

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

ReputationEventStream

Declaration
public IObservable<IPeerReputationChange> ReputationEventStream { get; }
Property Value
Type Description
System.IObservable<IPeerReputationChange>

Methods

| Improve this Doc View Source

Dispose()

Declaration
public void Dispose()
| Improve this Doc View Source

MergeReputationStream(IObservable<IPeerReputationChange>)

Allows passing a reputation streams to merge with the MasterReputationEventStream

Declaration
public void MergeReputationStream(IObservable<IPeerReputationChange> reputationChangeStream)
Parameters
Type Name Description
System.IObservable<IPeerReputationChange> reputationChangeStream
Exceptions
Type Condition
System.NotImplementedException
| Improve this Doc View Source

OnNext(IPeerReputationChange)

Declaration
public void OnNext(IPeerReputationChange peerReputationChange)
Parameters
Type Name Description
IPeerReputationChange peerReputationChange

Implements

System.IDisposable