Updating reader to use new Consumer interface--it's still slower.
3 files changed
tree: 2bee8bcdb4e5c86624f090cc02d78cf40f7411fb
  1. example/
  2. .gitignore
  3. barrier.go
  4. consumer.go
  5. cursor.go
  6. reader.go
  7. writer.go