Subscription
constructor(name: String, filter: SubscriptionFilter, startFrom: StartFrom = StartFrom.BEGINNING, decoder: EntryDecoder = EntryDecoder.RECORDS, models: Collection<AggregateModel<*>> = emptyList(), kind: FunctionKind = FunctionKind.PROJECT, context: String = filter.context, retry: HandlerRetry? = null, handler: suspend (SubscribedEntry) -> Unit)