Class StoreStreamImpl<T, E>

constructor

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

• Type parameters

  • T

  • E = any

  Parameters

  • stream: Observable<MutationRequestWrapper<T, E>>

  • log: Logger

  Returns StoreStreamImpl<T, E>