Code

Subscriber iterator#2039

Code

Open

ApostolFet wants to merge 15 commits intoairtai:0.6.0airtai/faststream:0.6.0from ApostolFet:subscriber-iteratorApostolFet/faststream:subscriber-iteratorCopy head branch name to clipboard

+700-11

Commits

Commits on Jan 13, 2025

• feat: rabbit subscriber iterator

  ApostolFet

  committed
  43ecb28

  Copy full SHA for 43ecb28

• test: rabbit subscriber iterator

  ApostolFet

  committed
  2a3edff

  Copy full SHA for 2a3edff

• test: use async for loop for test async iterator

  ApostolFet

  committed
  4fc7dc3

  Copy full SHA for 4fc7dc3

Commits on Jan 28, 2025

• feat: add __aiter__ method in SubscriberProto

  ApostolFet

  committed
  ab10944

  Copy full SHA for ab10944

• fix: return RabbitMessage everytime, ignore override

  ApostolFet

  committed
  1503b07

  Copy full SHA for 1503b07

• feat: kafka subscriber iterator

  ApostolFet

  committed
  636a7fb

  Copy full SHA for 636a7fb

Commits on Feb 3, 2025

• feat: add subscriber iterator for nats

  ApostolFet

  committed
  8bc66fb

  Copy full SHA for 8bc66fb

Commits on Feb 9, 2025

• feat: add subscriber iterator for redis

  ApostolFet

  committed
  02ba2f3

  Copy full SHA for 02ba2f3

Commits on Feb 10, 2025

• feat: add subscriber iterator for confluent

  ApostolFet

  committed
  625d203

  Copy full SHA for 625d203

Commits on Feb 15, 2025

• fix: type hint fixes and formatting

  ApostolFet

  committed
  ec62fad

  Copy full SHA for ec62fad

Commits on Feb 16, 2025

• fix: type hint fixes and formatting

  ApostolFet

  committed
  d2886a4

  Copy full SHA for d2886a4

• test: add test iterator in base consume

  ApostolFet

  committed
  0459213

  Copy full SHA for 0459213

• test: add test iterator for nats js, kv, os and etc

  ApostolFet

  committed
  da744a7

  Copy full SHA for da744a7

• test: add test iterator for redis list and stream

  ApostolFet

  committed
  c21a716

  Copy full SHA for c21a716

• chore: fix typo

  ApostolFet

  committed
  00435ed

  Copy full SHA for 00435ed