()

(createTweetDto: CreateTweetDto)

(msgChan chan *ckafka.Message)

(emailChan chan Email, workerId int)

()

( { offset, limit }: { offset: number; limit: number } = { offset: 0, limit: 50, }, )

()

()

(id: number)

()

(id: number, updateTweetDto: UpdateTweetDto)

(props)

()

()

({ Component, pageProps }: AppProps)

(props: Props)

(configMap *ckafka.ConfigMap, topics []string)

()

()

(props)

(props)

(props)

()

(private readonly appService: AppService)

(private readonly mailListService: MailListService)

( @InjectModel(MailList.name) private mailListModel: Model<MailListDocument>, )

( private mailListService: MailListService, @Inject('KAFKA_PRODUCER') private kafkaProducer: Produ

(private readonly tweetsService: TweetsService)

( @InjectModel(Tweet.name) private tweetModel: Model<TweetDocument>, )

( private tweetService: TweetsService, @Inject(CACHE_MANAGER) private cache: Cache, @InjectQue

(@Body() createMailListDto: CreateMailListDto)

({ emails }: CreateMailListDto)

(@Body() createTweetDto: CreateTweetDto)

(url: string)

(url: string)

()

(@Res() res)

(@Param('id') id: string)

(id: number)

()

(context)

(job: Job)

()

( req: NextApiRequest, res: NextApiResponse<Data> )

()

(event: FormEvent)

(@Param('id') id: string)

(@Param('id') id: string, @Body() updateTweetDto: UpdateTweetDto)