utils.SubscribableObserver

@nevermined-io/nevermined-sdk-js / utils / SubscribableObserver

Class: SubscribableObserver<T, P>

utils.SubscribableObserver

Type parameters

Name
T
P

Table of contents

Constructors

• constructor

Properties

• completed
• subscriptions

Methods

• complete
• emit
• error
• next
• subscribe
• unsubscribe

Constructors

constructor

• new SubscribableObserver<T, P>()

Type parameters

Name
T
P

Properties

completed

• completed: boolean = false

Defined in

src/utils/SubscribableObserver.ts:2

---

subscriptions

• Private subscriptions: Set<{ onComplete?: (complete: P) => void ; onError?: (error: any) => void ; onNext?: (next: T) => void }>

Defined in

src/utils/SubscribableObserver.ts:4

Methods

complete

▸ complete(resolve?): void

Parameters

Name	Type
resolve?	P

Returns

void

Defined in

src/utils/SubscribableObserver.ts:30

---

emit

▸ Private emit(type, value): void

Parameters

Name	Type
type	"onError" | "onNext" | "onComplete"
value	any

Returns

void

Defined in

src/utils/SubscribableObserver.ts:40

---

error

▸ error(error?): void

Parameters

Name	Type
error?	any

Returns

void

Defined in

src/utils/SubscribableObserver.ts:35

---

next

▸ next(next?): void

Parameters

Name	Type
next?	T

Returns

void

Defined in

src/utils/SubscribableObserver.ts:26

---

subscribe

▸ subscribe(onNext?, onComplete?, onError?): Object

Parameters

Name	Type
onNext?	(next: T) => void
onComplete?	(complete: P) => void
onError?	(error: any) => void

Returns

Object

Name	Type
unsubscribe	() => boolean

Defined in

src/utils/SubscribableObserver.ts:10

---

unsubscribe

▸ Private unsubscribe(): void

Returns

void

Defined in

src/utils/SubscribableObserver.ts:47