const Dict config

Configuration options for subscription

Bool isSubscribed()

Return if this subscription is still active

Bool isUnsubscribed()

Return if this subscription has been cancelled

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

Constructor

const Observable observable

Observable producing data items

const Observer observer

Subscribed observer consuming data items

Future send(Observation msg)

Send observation message to observer actor

Future sync()

Send sync message to observer actor

override Str toStr()

Debug string

Void unsubscribe()

Convenience for Observable.unsubscribe(this)