Code

implements flush.AsyncMessageSink#4

Code

Merged

jakekeeys merged 8 commits intouw-labs:masteruw-labs/substrate-tools:masterfrom kaperys:flush-wrapperkaperys/substrate-tools:flush-wrapperCopy head branch name to clipboardJul 20, 2020

+652

Commits

Commits on Jul 15, 2020

• implements flush.AsyncMessageSink

  kaperys

  committed
  639cd8d

  Copy full SHA for 639cd8d

• fix flushing wrapper readme

  kaperys

  committed
  5c87687

  Copy full SHA for 5c87687

• update flushing example and add to readme

  kaperys

  committed
  7e89c67

  Copy full SHA for 7e89c67

Commits on Jul 16, 2020

• improve goroutine lifecycle management, context propagation, channel management and greater unit test coverage

  kaperys

  committed
  127e1fc

  Copy full SHA for 127e1fc

• simplify acking goroutine

  kaperys

  committed
  a9cc2c2

  Copy full SHA for a9cc2c2

• PublishMessages returns substrate.ErrSinkAlreadyClosed

  kaperys

  committed
  47c3717

  Copy full SHA for 47c3717

• don't close msgCh

  kaperys

  committed
  1743c2c

  Copy full SHA for 1743c2c

• return ctx.Error() for PublishMessage context

  kaperys

  committed
  ba2007a

  Copy full SHA for ba2007a