RetroSearch Browse

Showing content from https://richardschneider.github.io/net-ipfs-core/api/Ipfs.CoreApi.IPubSubApi.html below:

Interface IPubSubApi

Allows you to publish messages to a given topic, and also to subscribe to new messages on a given topic.

Namespace: Ipfs.CoreApi Assembly: Ipfs.Core.dll Syntax

public interface IPubSubApi

Methods | Improve this Doc View Source PeersAsync(String, CancellationToken)

Get the peers that are pubsubing with us.

Declaration

Task<IEnumerable<Peer>> PeersAsync(string topic = null, CancellationToken cancel = default(CancellationToken))

Parameters Returns Type Description Task<IEnumerable<Peer>>

A task that represents the asynchronous operation. The task's value is a sequence of Peer.

| Improve this Doc View Source PublishAsync(String, Byte[], CancellationToken)

Publish a binary message to a given topic.

Declaration

Task PublishAsync(string topic, byte[] message, CancellationToken cancel = default(CancellationToken))

Parameters Returns Type Description Task

A task that represents the asynchronous operation.

| Improve this Doc View Source PublishAsync(String, Stream, CancellationToken)

Publish a binary message to a given topic.

Declaration

Task PublishAsync(string topic, Stream message, CancellationToken cancel = default(CancellationToken))

Parameters Returns Type Description Task

A task that represents the asynchronous operation.

| Improve this Doc View Source PublishAsync(String, String, CancellationToken)

Publish a string message to a given topic.

Declaration

Task PublishAsync(string topic, string message, CancellationToken cancel = default(CancellationToken))

Parameters Returns Type Description Task

A task that represents the asynchronous operation.

| Improve this Doc View Source SubscribeAsync(String, Action<IPublishedMessage>, CancellationToken)

Subscribe to messages on a given topic.

Declaration

Task SubscribeAsync(string topic, Action<IPublishedMessage> handler, CancellationToken cancellationToken)

Parameters Returns Type Description Task

A task that represents the asynchronous operation.

| Improve this Doc View Source SubscribedTopicsAsync(CancellationToken)

Get the subscribed topics.

Declaration

Task<IEnumerable<string>> SubscribedTopicsAsync(CancellationToken cancel = default(CancellationToken))

Parameters Returns Type Description Task<IEnumerable<String>>

A task that represents the asynchronous operation. The task's value is a sequence of String for each topic.