JS API Reference
Class: EventReader
shared/yagna/event-reader.EventReader
Table of contents
Constructors
Methods
Constructors
constructor
• new EventReader(logger): EventReader
Parameters
| Name | Type |
|---|---|
logger | Logger |
Returns
Defined in
src/shared/yagna/event-reader.ts:28
Methods
pollToSubject
▸ pollToSubject<T>(generator, subject): Promise<void>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
generator | AsyncGenerator<T, any, unknown> |
subject | Subject<T> |
Returns
Promise<void>
Defined in
src/shared/yagna/event-reader.ts:30
createReader
▸ createReader<T>(eventType, eventsFetcher): CancellablePoll<T>
Type parameters
| Name | Type |
|---|---|
T | extends Event |
Parameters
| Name | Type |
|---|---|
eventType | string |
eventsFetcher | CancellableEventsFetcherWithCursor<T> |
Returns
Defined in
Was this helpful?