Skip to content

Commit

Permalink
Documentation
Browse files Browse the repository at this point in the history
  • Loading branch information
teivah committed Feb 17, 2020
1 parent adcbda8 commit f221e2f
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -310,6 +310,7 @@ In this example, we create a pool of 32 goroutines that consume items concurrent
* [Retry](http://reactivex.io/documentation/operators/retry.html) — if a source Observable sends an onError notification, resubscribe to it in the hopes that it will complete without error

### Observable Utility Operators
* [Do](http://reactivex.io/documentation/operators/do.html) - register an action to take upon a variety of Observable lifecycle events
* Run - create an Observer without consuming the emitted items
* Send - send the Observable items in a specific channel
* ToMap/ToMapWithValueSelector - stores the Observable items in a map
Expand Down
2 changes: 1 addition & 1 deletion iterable.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package rxgo

// Iterable is the interface returning an iterable channel.
// Iterable is the basic type that can be observed.
type Iterable interface {
Observe() <-chan Item
}

0 comments on commit f221e2f

Please sign in to comment.