Skip to content

Commit

Permalink
Documentation update
Browse files Browse the repository at this point in the history
  • Loading branch information
teivah committed Feb 25, 2020
1 parent eb4087a commit 6263554
Showing 1 changed file with 2 additions and 10 deletions.
12 changes: 2 additions & 10 deletions doc/fromeventsource.md
Original file line number Diff line number Diff line change
Expand Up @@ -17,17 +17,9 @@ observable := rxgo.FromEventSource(ch)

* WithBackPressureStrategy

* Block (default): block until the Observer is ready to consume the next item.
* Block (default): block until the Observer is ready to consume the next item using `rxgo.WithBackPressureStrategy(rxgo.Block)`

```go
rxgo.FromEventSource(ch, rxgo.WithBackPressureStrategy(rxgo.Block))
```

* Drop: drop the item if the Observer isn't ready.

```go
rxgo.FromEventSource(ch, rxgo.WithBackPressureStrategy(rxgo.Drop))
```
* Drop: drop the item if the Observer isn't ready using `rxgo.WithBackPressureStrategy(rxgo.Drop)`

* [WithBufferedChannel](options.md#withbufferedchannel)

Expand Down

0 comments on commit 6263554

Please sign in to comment.