code: func (reactorFunc KinesisReactorFunc) OnKinesisMessage(ctx context.Context,
  	kinesisEvent awsLambdaEvents.KinesisEvent) (interface{}, error) {
  	return reactorFunc(ctx, kinesisEvent)
  }
docs: // OnKinesisMessage satisfies the KinesisReactor interface