Observable

Undocumented in source.

struct Observable (

T

Mutex = DummyMutex

) {

import std.traits : isImplicitlyConvertible;;

Observer!(T)[void*] observer;

alias Type = T;

typeof(this) opAssign(T newValue);

size_t length [@property getter];

void subscribe(void delegate(ref const(T)) @(safe) onMsg);

void subscribe(void delegate(ref const(T)) @(safe) onMsg, void delegate() @(safe) onClose);

void unSubscribe(void delegate(ref const(T)) @(safe) onMsg);

void push(const(S) value);

void publish();

}

Destructor

~this ~this(): Undocumented in source.

Members

Aliases

Type alias Type = T: Undocumented in source.

Functions

opAssign typeof(this) opAssign(T newValue): Undocumented in source. Be warned that the author may not have intended to support it.
opCast T opCast(): Undocumented in source. Be warned that the author may not have intended to support it.
publish void publish(): Undocumented in source. Be warned that the author may not have intended to support it.
push void push(const(S) value): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(void delegate(ref const(T)) @(safe) onMsg): Undocumented in source. Be warned that the author may not have intended to support it.
subscribe void subscribe(void delegate(ref const(T)) @(safe) onMsg, void delegate() @(safe) onClose): Undocumented in source. Be warned that the author may not have intended to support it.
unSubscribe void unSubscribe(void delegate(ref const(T)) @(safe) onMsg): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

length size_t length [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Variables

mutex Mutex mutex;: Undocumented in source.
observer Observer!(T)[void*] observer;: Undocumented in source.
value T value;: Undocumented in source.

Meta

Source

See Implementation

observable structs

Observable