@theophilusdev/conduit
    Preparing search index...

    Interface MessageCollectorEvents<T>

    Event map for message collectors.

    interface MessageCollectorEvents<T = unknown> {
        collect: (message: T) => any;
        end: (collected: ReadonlyMap<string, T>, reason: CollectorEndReason) => any;
    }

    Type Parameters

    • T = unknown
    Index

    Properties

    Properties

    collect: (message: T) => any
    end: (collected: ReadonlyMap<string, T>, reason: CollectorEndReason) => any