Interface IEventStoreSubscriptions

An event store that can be subscribed to

interface IEventStoreSubscriptions {
    addressable(pointer: AddressPointer): Observable<undefined | Event>;
    event(id: string | EventPointer): Observable<undefined | Event>;
    filter(filters: Filter | Filter[]): Observable<Event[]>;
    replaceable(pointer: AddressPointerWithoutD): Observable<undefined | Event>;
}

Index

Methods

addressable event filter replaceable

Methods

addressable

addressable(pointer: AddressPointer): Observable<undefined | Event>
Subscribe to an addressable event by pointer
Parameters
- pointer: AddressPointer
Returns Observable<undefined | Event>
- Defined in packages/core/src/event-store/interface.ts:70

event

event(id: string | EventPointer): Observable<undefined | Event>
Susbscribe to an event by id
Parameters
- id: string | EventPointer
Returns Observable<undefined | Event>
- Defined in packages/core/src/event-store/interface.ts:66

filter

filter(filters: Filter | Filter[]): Observable<Event[]>
Subscribe to a batch of events that match the filters
Parameters
- filters: Filter | Filter[]
Returns Observable<Event[]>
- Defined in packages/core/src/event-store/interface.ts:72

replaceable

replaceable(pointer: AddressPointerWithoutD): Observable<undefined | Event>
Subscribe to a replaceable event by pointer
Parameters
- pointer: AddressPointerWithoutD
Returns Observable<undefined | Event>
- Defined in packages/core/src/event-store/interface.ts:68