Function startStream

Parameters

• config: LakeConfig

• onStreamerMessageReceived: ((data, context) => Promise<void>)

  • • (data, context): Promise<void>

    • Parameters

      • data: Block

      • context: LakeContext

      Returns Promise<void>