Class MutateStreamImpl<T, E>

Type parameters

T
E = any

Hierarchy

StoreStreamImpl<T>
- MutateStreamImpl

Implements

MutateStream<T, E>

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new MutateStreamImpl<T, E>(stream: Observable<MutationRequestWrapper<T, E>>, log: Logger): MutateStreamImpl<T, E>

Overrides StoreStreamImpl.constructor
- Defined in src/bus/store/store.model.ts:146
Type parameters
- T
- E = any
Parameters
- stream: Observable<MutationRequestWrapper<T, E>>
- log: Logger
Returns MutateStreamImpl<T, E>

Properties

Protected log

log: Logger

Protected mutatorErrorHandler

mutatorErrorHandler: MessageFunction<E>

Protected mutatorSuccessHandler

mutatorSuccessHandler: MessageFunction<T>

Protected stream

stream: Observable<MutationRequestWrapper<T, E>>

Protected subscription

subscription: Subscription

Methods

error

error(error: E): void

Implementation of MutateStream.error
- Defined in src/bus/store/store.model.ts:177
Something went wrong with mutation

Parameters
- error: E
Returns void

subscribe

subscribe(successHandler: MessageFunction<T>): Subscription

Implementation of MutateStream.subscribe
Overrides StoreStreamImpl.subscribe
- Defined in src/bus/store/store.model.ts:150
Subscribe to Observable stream.

Parameters
- successHandler: MessageFunction<T>
Returns Subscription
subscription to stream.

success

success(success: T): void

Implementation of MutateStream.success
- Defined in src/bus/store/store.model.ts:188
The mutation was a success!

Parameters
- success: T
Returns void

unsubscribe

unsubscribe(): void

Implementation of MutateStream.unsubscribe
Inherited from StoreStreamImpl.unsubscribe
- Defined in src/bus/store/store.model.ts:134
Unsubscribe from Observable stream.

Returns void

Generated using TypeDoc