io.ipfs.api

Class IPFS.Pubsub

java.lang.Object

io.ipfs.api.IPFS.Pubsub

Enclosing class:

IPFS

public class IPFS.Pubsub
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Pubsub()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	ls()
java.lang.Object	peers()
java.lang.Object	peers(java.lang.String topic)
java.lang.Object	pub(java.lang.String topic, java.lang.String data)
java.util.stream.Stream<java.util.Map<java.lang.String,java.lang.Object>>	sub(java.lang.String topic)
void	sub(java.lang.String topic, java.util.function.Consumer<java.util.Map<java.lang.String,java.lang.Object>> results, java.util.function.Consumer<java.io.IOException> error) A synchronous method to subscribe which consumes the calling thread
java.util.stream.Stream<java.util.Map<java.lang.String,java.lang.Object>>	sub(java.lang.String topic, java.util.concurrent.ForkJoinPool threadSupplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Pubsub

public Pubsub()

Method Detail

ls

public java.lang.Object ls()
                    throws java.io.IOException

Throws:

java.io.IOException

peers

public java.lang.Object peers()
                       throws java.io.IOException

Throws:

java.io.IOException

peers

public java.lang.Object peers(java.lang.String topic)
                       throws java.io.IOException

Throws:

java.io.IOException

pub

public java.lang.Object pub(java.lang.String topic,
                            java.lang.String data)
                     throws java.lang.Exception

Throws:

java.lang.Exception

sub

public java.util.stream.Stream<java.util.Map<java.lang.String,java.lang.Object>> sub(java.lang.String topic)
                                                                              throws java.lang.Exception

Throws:

java.lang.Exception

sub

public java.util.stream.Stream<java.util.Map<java.lang.String,java.lang.Object>> sub(java.lang.String topic,
                                                                                     java.util.concurrent.ForkJoinPool threadSupplier)
                                                                              throws java.lang.Exception

Throws:

java.lang.Exception

sub

public void sub(java.lang.String topic,
                java.util.function.Consumer<java.util.Map<java.lang.String,java.lang.Object>> results,
                java.util.function.Consumer<java.io.IOException> error)
         throws java.io.IOException

A synchronous method to subscribe which consumes the calling thread

Parameters:

topic -

results -

Throws:

java.io.IOException