Code

Feature/col 3 rewind#62

Code

Merged

mschristensen merged 24 commits intomainably-labs/models:mainfrom feature/COL-3-rewindably-labs/models:feature/COL-3-rewindCopy head branch name to clipboardOct 23, 2023

+1,295-350

Commits

Commits on Oct 23, 2023

• stream: move stream processing to middleware

  Show description for 5e4d90a
  mschristensen

  committed
  5e4d90a

• stream: add unsubscribeAll to middleware

  mschristensen

  committed
  e20cf98

• stream: integrate with OrderedSequenceResumer

  mschristensen

  committed
  a24cdfe

• stream: add null checks

  mschristensen

  committed
  9f896e4

• model: integrate sync func with stream rewind

  Show description for f68d195
  mschristensen

  committed
  f68d195

• stream: pass absolute number for rewind not string

  mschristensen

  committed
  905cd01

• model: test stream sync with rewind used correctly

  mschristensen

  committed
  c915aef

• middleware: override next method on base class

  mschristensen

  committed
  484046f

• middleware: fix call unsubscripe on super

  mschristensen

  committed
  72a65da

• middleware: descriptive id comparison methods

  mschristensen

  committed
  ac99401

• model: extract stream callback to class method

  mschristensen

  committed
  a186481

• stream: resync with paginated history until attach

  Show description for 6754f8f
  mschristensen

  committed
  6754f8f

• middleware: fix history message emit order

  mschristensen

  committed
  d1ce164

• stream: add stream error state and reset

  mschristensen

  committed
  591595a

• test: add stream sync tests with history

  mschristensen

  committed
  3b74760

• middleware: order numeric fallback lexicographic

  mschristensen

  committed
  e1bc74a

• middleware: update comments and docstrings

  mschristensen

  committed
  dd4a6a2

• model: use statePromise

  mschristensen

  committed
  84c9b90

• middleware: flush on empty history page

  mschristensen

  committed
  4f4551a

• middleware: descriptive message before method

  mschristensen

  committed
  0d624f4

• middleware: fix handle entry history pages

  mschristensen

  committed
  22bf584

• stream: use implicit attach from subscribe call

  mschristensen

  committed
  a15f05b

• stream: rename sync to replay

  mschristensen

  committed
  02ea83b

• test: fix tests after rebase

  mschristensen

  committed
  f65b0e7