import { AppSyncClient } from '../common_services'; import { DeviceStatusCheckFn, DbStreamConverterFn } from '../types.d'; export declare abstract class UpdateEventPublisher { private readonly appSyncClient$; readonly checkDeviceStatus: DeviceStatusCheckFn; constructor(appSyncClient$: AppSyncClient, checkDeviceStatus: DeviceStatusCheckFn); abstract prepareUpdateEventRequest(item: any, keys: any): any; /** * * @param stream stream of update events coming from DynamoDb * @param streamConverterFn Function used to convert the event records to type interfaces */ publishUpdateEventToSubscribers(stream: Array, streamConverterFn: DbStreamConverterFn): Promise; }