Code

Version 3#377

Code

Closed

si3nloong wants to merge 105 commits intoReactiveX:v3ReactiveX/RxGo:v3from si3nloong:v3si3nloong/RxGo:v3Copy head branch name to clipboard

+19,313-37,793

Commits

Commits on Aug 22, 2022

• upgrade: remove vendor and bump go to v1.18 to support generics

  si3nloong

  committed
  b07fe0d

Commits on Aug 27, 2022

• refactor: observable API using generic

  si3nloong

  committed
  4a10a56

Commits on Aug 29, 2022

• fix: CI

  si3nloong

  committed
  a6ed0a5

• fix: golangci-lint

  si3nloong

  committed
  fc52b6b

• refactor: rework observable API using generics, added Take, Filter, Map operators

  si3nloong

  committed
  bf2b5da

• chore: add more operators

  si3nloong

  committed
  07da982

• chore: allow count to be generic

  si3nloong

  committed
  c22b157

• fix: defer unsubscribe to prevent dangling channel

  si3nloong

  committed
  b3af599

• chore: add comments

  si3nloong

  committed
  4e04e78

• fix: types

  si3nloong

  committed
  21ef76a

Commits on Aug 30, 2022

• chore: added ConcatMap API

  si3nloong

  committed
  2e96aff

• chore: rename files

  si3nloong

  committed
  0e9af5b

• fix: test (disable the old debounce testing)

  si3nloong

  committed
  8ef339c

Commits on Aug 31, 2022

• fix: send data on closed channel

  si3nloong

  committed
  ec0beba

• chore: add operator ToArray

  si3nloong

  committed
  c9b9050

• fix: tests

  si3nloong

  committed
  7a8b2c7

• chore: added test cases

  si3nloong

  committed
  a0d2f2b

• chore: added new operator Count

  si3nloong

  committed
  e0b8696

Commits on Sep 1, 2022

• chore: add new operator Skip and fix ElementAt operator bug

  si3nloong

  committed
  ae81537

• ✅ test: added test cases

  si3nloong

  committed
  23b26b8

• 🧪 test: added more tests

  si3nloong

  committed
  64e8d22

• chore: add Tap and Timestamp operator

  si3nloong

  committed
  01ae82b

• 🐛 fix: consumeStreamUntil bug, it shouldn't call Complete if error occurred

  si3nloong

  committed
  4de9202

Commits on Sep 4, 2022

• refactor: use embedded struct for safeSubscriber

  si3nloong

  committed
  45591de

• chore: added Done to notification, added Some and None nomad

  si3nloong

  committed
  73ca684

Commits on Sep 5, 2022

• ♻️ refactor: stream structure

  si3nloong

  committed
  4e014c4

Commits on Sep 6, 2022

• fix: test

  si3nloong

  committed
  ebc35d5

• chore: disable random leak test

  si3nloong

  committed
  6c003c3

• fix: operator DistinctUntilChanged

  si3nloong

  committed
  8d7f2f4

• test: added tests and added TimeInterval

  si3nloong

  committed
  98050c9

• refactor: rename Data to Notification

  si3nloong

  committed
  aadf897

• fix: test

  si3nloong

  committed
  b45d53c

Commits on Sep 8, 2022

• fix: ConcatMap business logic

  si3nloong

  committed
  f68955a

• fix: don't send on closed channel

  si3nloong

  committed
  761c9d5

• fix: timestamp should be UTC

  si3nloong

  committed
  0668d58

• 🐛 fix: test

  si3nloong

  committed
  6518064

• fix: golangci-lint failed on windows (golangci/golangci-lint#3134)

  si3nloong

  committed
  3f0ade3

• chore: downgrade golangci-lint

  si3nloong

  committed
  ac12383

• ✅ test: add more tests and fix some minor bugs

  si3nloong

  committed
  096e672

• 🧪 test: added more tests

  si3nloong

  committed
  f5209d2

• chore: some updates

  si3nloong

  committed
  f8c9ba8

Commits on Sep 9, 2022

• feat: updated new API and deprecated old API

  si3nloong

  committed
  854e634

• refactor: codes

  si3nloong

  committed
  367260c

• refactor: filter and skip operation

  si3nloong

  committed
  db15c72

Commits on Sep 10, 2022

• feat: finish DebounceTime and ThrottleTime API

  si3nloong

  committed
  bfcab71

• feat: introduce join operators, ForkJoin and Zip

  si3nloong

  committed
  1c412a4

• chore: drafting GroupedObservable and CombineLatest

  si3nloong

  committed
  f264b49

Commits on Sep 11, 2022

• feat: added Timeout

  si3nloong

  committed
  77b3a72

Commits on Sep 12, 2022

• fix: CombineLatestWith API and added Timeout API

  si3nloong

  committed
  4470ff7

• chore: set minimum to go 1.19 and comment old codes

  si3nloong

  committed
  f9d144e

• chore: bump golangci-lint

  si3nloong

  committed
  f5d0951

• fix: test

  si3nloong

  committed
  09fcae3

• fix: Timeout

  si3nloong

  committed
  28f5d0c

• chore: temporary disable Timeout test

  si3nloong

  committed
  de94dcf

• fix: Timeout operator

  si3nloong

  committed
  94940b2

• chore: added ExhaustMap operator

  si3nloong

  committed
  5ee5dd1

• fix: transformation operators

  si3nloong

  committed
  19b1df7

Commits on Sep 13, 2022

• chore: added ThrowError, CatchError, and ThrowIfEmpty operators

  si3nloong

  committed
  6b5b753

• doc: update README

  si3nloong

  committed
  257857c

Commits on Sep 14, 2022

• chore: added Single operator

  si3nloong

  committed
  755263d

Commits on Sep 15, 2022

• chore: working on Buffer API

  si3nloong

  committed
  7ee4be1

Commits on Sep 17, 2022

• fix: Zip actual behaviour

  si3nloong

  committed
  52ab1c9

• chore: bump go.mod

  si3nloong

  committed
  afcb3a5

• chore: added Dematerialize API

  si3nloong

  committed
  d9f4040

• chore: added Sample API

  si3nloong

  committed
  f2e32d5

• fix: Repeat and Retry

  si3nloong

  committed
  740679b

• fix: Defer, Retry, Repeat and ZipWith

  si3nloong

  committed
  2cde193

Commits on Sep 18, 2022

• 🐛 fix: ZipWith and ZipAll

  si3nloong

  committed
  db76f67

• chore: fix Audit API

  si3nloong

  committed
  5800968

• doc: update README

  si3nloong

  committed
  29a4fd0

• fix: timeout on CI

  si3nloong

  committed
  f8ee7b1

Commits on Sep 21, 2022

• refactor: rename some function name based on ReactiveX standard

  si3nloong

  committed
  35b0014

• fix: test

  si3nloong

  committed
  acd52ca

• refactor: rename functions

  si3nloong

  committed
  614e1e0

• fix: test

  si3nloong

  committed
  bbca89a

• chore: complete ConcatWith API

  si3nloong

  committed
  581c28c

Commits on Sep 22, 2022

• fix: several operators, such as ForkJoin, CombineLatestAll, CombineLatestWith, etc

  si3nloong

  committed
  d98490d

• chore: complete SequenceEqual API

  si3nloong

  committed
  50a32b9

• docs: update API documentation

  si3nloong

  committed
  991eed6

• docs: update READMEs

  si3nloong

  committed
  b353f09

• fix: golangci-lint error

  si3nloong

  committed
  b7e4aa9

Commits on Sep 23, 2022

• test: add tests

  si3nloong

  committed
  c03c693

Commits on Sep 26, 2022

• refactor: change Optional to interface instead and add some tests

  si3nloong

  committed
  723bd14

• fix: BufferCount and update documentations

  si3nloong

  committed
  516db52

Commits on Oct 2, 2022

• chore: update RaceWith API and add new function IsEnd to ObservableNotification interface

  si3nloong

  committed
  7cbdb1d

• docs: update README

  si3nloong

  committed
  fe40c54

• docs: update README and fix test

  si3nloong

  committed
  b381207

Commits on Oct 3, 2022

• docs: update documentation

  si3nloong

  committed
  13d30b8

• fix: test

  si3nloong

  committed
  8aec543

Commits on Oct 17, 2022

• docs: update API documentation

  si3nloong

  committed
  58ccc46

• docs: update docs

  si3nloong

  committed
  17080c6

• fix: test

  si3nloong

  committed
  0fdf245

• docs: update README

  si3nloong

  committed
  cb9eca3

Commits on Oct 24, 2022

• docs: update documentation

  si3nloong

  committed
  0696952

Commits on Oct 25, 2022

• fix: optional and added documentation

  si3nloong

  committed
  8a7e1e4

• chore: upgrade golangci-lint

  si3nloong

  committed
  4ce2df5

Commits on Oct 27, 2022

• chore: add APIs

  si3nloong

  committed
  31c13ab

• fix: catch

  si3nloong

  committed
  c657d5d

• fix: CI

  si3nloong

  committed
  5425ffd

• docs: update API documentation

  si3nloong

  committed
  6ee6b6a

• chore: update

  si3nloong

  committed
  54023b4

• chore: remove old code

  si3nloong

  committed
  6fc0cfc

• docs: update README

  si3nloong

  committed
  ff33b14

• fix: test

  si3nloong

  committed
  3bbb929

• fix: documentation

  si3nloong

  committed
  a806540