import Subscription from 'fastflux/core/observable/subscription'

public class | source

Subscription

Example:

let emitter = new Observable;
let log = (v) => console.log("Received:", v);

let subscription = new Subscription(emitter, log);
assert(!subscription.isActive());

subscription.activate();
assert(subscription.isActive());

subscription.terminate();
assert(!subscription.isActive());

Constructor Summary

Public Constructor
public	constructor(source: Observable, subscriber: function)

Method Summary

Public Methods
public	activate() Equivalent to `source.subscribe(subscriber)`
public	isActive(): boolean Equivalent to `source.hasSubscribed(subscriber)`
public	terminate() Equivalent to `source.unsubscribe(subscriber)`

Public Constructors

public constructor(source: Observable, subscriber: function) source

Params:

Name	Type	Attribute	Description
source	Observable
subscriber	function

Public Methods

public activate() source

Equivalent to source.subscribe(subscriber)

See Observable#subscribe

public isActive(): boolean source

Equivalent to source.hasSubscribed(subscriber)

See Observable#hasSubscribed

Return:

boolean

public terminate() source

Equivalent to source.unsubscribe(subscriber)

See Observable#unsubscribe