type

Subscription

const class Subscription : Obj

Subscription models an Observable to Observer binding

NOTE: this API is subject to change

constructors

make

Constructor

fields

config

Configuration options for subscription

observable

Observable producing data items

observer

Subscribed observer consuming data items

methods

isSubscribed

Return if this subscription is still active

isUnsubscribed

Return if this subscription has been cancelled

send

Send observation message to observer actor

sync

Send sync message to observer actor

toStr

Debug string

unsubscribe

Convenience for Observable.unsubscribe(this)

Slot Details

config

const Dict config

Configuration options for subscription

isSubscribed

Bool isSubscribed()

Return if this subscription is still active

isUnsubscribed

Bool isUnsubscribed()

Return if this subscription has been cancelled

make

new make(Observable observable, Observer observer, Dict config)

Constructor

observable

const Observable observable

Observable producing data items

observer

const Observer observer

Subscribed observer consuming data items

send

Future send(Observation msg)

Send observation message to observer actor

sync

Future sync()

Send sync message to observer actor

toStr

override Str toStr()

Debug string

unsubscribe

Void unsubscribe()

Convenience for Observable.unsubscribe(this)