Module software.sava.rpc

Package software.sava.rpc.json.http.ws

Interface Subscription<T>

All Superinterfaces:

Consumer<T>, Runnable

public interface Subscription<T>
extends Consumer<T>, Runnable

Method Summary

Modifier and Type	Method	Description
void	accept(T t)
Channel	channel()
Commitment	commitment()
static <T> Subscription<T>	createAccountSubscription(Commitment commitment, Channel channel, software.sava.core.accounts.PublicKey publicKey, long msgId, String msg, Consumer<Subscription<T>> onSub, Consumer<T> consumer)
static <T> Subscription<T>	createSubscription(Commitment commitment, Channel channel, String key, long msgId, String msg, Consumer<Subscription<T>> onSub, Consumer<T> consumer)
String	key()
long	lastAttempt()
String	msg()
long	msgId()
software.sava.core.accounts.PublicKey	publicKey()
void	setLastAttempt(long lastAttempt)
void	setSubId(long subId)
long	subId()

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface java.lang.Runnable

run

Method Details

createAccountSubscription

static <T> Subscription<T> createAccountSubscription(Commitment commitment,
 Channel channel,
 software.sava.core.accounts.PublicKey publicKey,
 long msgId,
 String msg,
 Consumer<Subscription<T>> onSub,
 Consumer<T> consumer)

createSubscription

static <T> Subscription<T> createSubscription(Commitment commitment,
 Channel channel,
 String key,
 long msgId,
 String msg,
 Consumer<Subscription<T>> onSub,
 Consumer<T> consumer)

accept

void accept(T t)

Specified by:

accept in interface Consumer<T>

channel

Channel channel()

commitment

Commitment commitment()

key

String key()

publicKey

software.sava.core.accounts.PublicKey publicKey()

msgId

long msgId()

msg

String msg()

lastAttempt

long lastAttempt()

setLastAttempt

void setLastAttempt(long lastAttempt)

subId

long subId()

setSubId

void setSubId(long subId)