Skip to content

Commit

Permalink
bump v1.34.0
Browse files Browse the repository at this point in the history
  • Loading branch information
samber committed Nov 11, 2022
1 parent 34ef81e commit 686821d
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 3 deletions.
9 changes: 8 additions & 1 deletion CHANGELOG.md
Expand Up @@ -2,11 +2,18 @@

@samber: I sometimes forget to update this file. Ping me on [Twitter](https://twitter.com/samuelberthe) or open an issue in case of error. We need to keep a clear changelog for easier lib upgrade.

## 1.34.0 (2022-10-xx)
## 1.34.0 (2022-11-12)

Improving:
- lo.Union: faster and can receive more than 2 lists

Adding:
- lo.FanIn (alias to lo.ChannelMerge)
- lo.FanOut

Deprecation:
- lo.ChannelMerge

## 1.33.0 (2022-10-14)

Adding:
Expand Down
5 changes: 3 additions & 2 deletions README.md
Expand Up @@ -1538,14 +1538,15 @@ for i := range children {

### FanIn

Collects messages from multiple input channels into a single buffered channel. Output messages has no priority. When all upstream channels reach EOF, downstream channel closes.
Merge messages from multiple input channels into a single buffered channel. Output messages has no priority. When all upstream channels reach EOF, downstream channel closes.

```go
stream1 := make(chan int, 42)
stream2 := make(chan int, 42)
stream3 := make(chan int, 42)

all := lo.FanIn(100, stream1, stream2, stream3)
// <-chan int
```

### FanOut
Expand All @@ -1555,7 +1556,7 @@ Broadcasts all the upstream messages to multiple downstream channels. When upstr
```go
stream := make(chan int, 42)

all := lo.FanOut(5, 42, stream)
all := lo.FanOut(5, 100, stream)
// [5]<-chan int
```

Expand Down

0 comments on commit 686821d

Please sign in to comment.