Show / Hide Table of Contents

Interface IMessageRouter

Routes pub/sub messages to other peers.

Inherited Members
IService.StartAsync()
IService.StopAsync()
Namespace: PeerTalk.PubSub
Assembly: PeerTalk.dll
Syntax
public interface IMessageRouter : IService

Methods

| Improve this Doc View Source

InterestedPeers(String)

Gets the sequence of peers interested in the topic.

Declaration
IEnumerable<Peer> InterestedPeers(string topic)
Parameters
Type Name Description
String topic

The topic of interest or null for all topics.

Returns
Type Description
IEnumerable<Peer>

A sequence of Peer that are subsribed to the topic.

| Improve this Doc View Source

JoinTopicAsync(String, CancellationToken)

Indicates that the local peer is interested in the topic.

Declaration
Task JoinTopicAsync(string topic, CancellationToken cancel)
Parameters
Type Name Description
String topic

The topic of interested.

CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.

Returns
Type Description
Task

A task that represents the asynchronous operation.

| Improve this Doc View Source

LeaveTopicAsync(String, CancellationToken)

Indicates that the local peer is no longer interested in the topic.

Declaration
Task LeaveTopicAsync(string topic, CancellationToken cancel)
Parameters
Type Name Description
String topic

The topic of interested.

CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.

Returns
Type Description
Task

A task that represents the asynchronous operation.

| Improve this Doc View Source

PublishAsync(PublishedMessage, CancellationToken)

Sends the message to other peers.

Declaration
Task PublishAsync(PublishedMessage message, CancellationToken cancel)
Parameters
Type Name Description
PublishedMessage message

The message to send.

CancellationToken cancel

Is used to stop the task. When cancelled, the TaskCanceledException is raised.

Returns
Type Description
Task

A task that represents the asynchronous operation.

Events

| Improve this Doc View Source

MessageReceived

Raised when a new message is received.

Declaration
event EventHandler<PublishedMessage> MessageReceived
Event Type
Type Description
EventHandler<PublishedMessage>
  • Improve this Doc
  • View Source
Back to top Generated by DocFX