Accessor

class Accessor (

T

) {

Transport tport;

QoS defaultQoS;

Duration waitTime;

Duration waitSleepStep;

size_t maxWaitResponses;

void delegate(Duration d) sleepFunc;

void sleep(Duration t);

RMISkeleton!T skeleton;

void receive(string t, RMICall call);

this(Transport t, T serv, string uniqName, void delegate(Duration) sf, Duration waitTime, Duration waitSleepStep, size_t maxWaitResponses);

this(Transport t, T serv, void delegate(Duration) sf);

void publish(string topic, V val, QoS qos);

void publish(string topic, const(ubyte)[] data, QoS qos);

Broadcaster getBroadcaster(string topic);

void subscribe(string topic, void delegate(string, const(ubyte)[]) dlg, QoS qos);

void subscribe(string bus, void delegate(string, V) dlg, QoS qos);

RMIStub!X getClient(string uniqName);

void connect();

bool connected();

}

Constructors

this this(Transport t, T serv, string uniqName, void delegate(Duration) sf, Duration waitTime, Duration waitSleepStep, size_t maxWaitResponses): Undocumented in source.
this this(Transport t, T serv, void delegate(Duration) sf): Undocumented in source.

Members

Classes

BCaster class BCaster: Undocumented in source.
CliCom class CliCom: Undocumented in source.

Functions

connect void connect(): Undocumented in source. Be warned that the author may not have intended to support it.
connected bool connected(): Undocumented in source. Be warned that the author may not have intended to support it.
getBroadcaster Broadcaster getBroadcaster(string topic): Undocumented in source. Be warned that the author may not have intended to support it.
getClient RMIStub!X getClient(string uniqName): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(string topic, V val, QoS qos): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(string topic, const(ubyte)[] data, QoS qos): Undocumented in source. Be warned that the author may not have intended to support it.
receive void receive(string t, RMICall call): Undocumented in source. Be warned that the author may not have intended to support it.
sleep void sleep(Duration t): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(string topic, void delegate(string, const(ubyte)[]) dlg, QoS qos): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(string bus, void delegate(string, V) dlg, QoS qos): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

defaultQoS QoS defaultQoS;: Undocumented in source.
maxWaitResponses size_t maxWaitResponses;: Undocumented in source.
name string name;: Undocumented in source.
sBuffer auto sBuffer;: Undocumented in source.
skeleton RMISkeleton!T skeleton;: Undocumented in source.
sleepFunc void delegate(Duration d) sleepFunc;: Undocumented in source.
tport Transport tport;: Undocumented in source.
waitSleepStep Duration waitSleepStep;: Undocumented in source.
waitTime Duration waitTime;: Undocumented in source.

Meta

Source

See Implementation

drmi ps accessor classes

Accessor

interfaces

Broadcaster

manifest constants