Send the Observable items to a given channel that will closed once the operation completes.
ch := make(chan rxgo.Item)
rxgo.Just(1, 2, 3)().Send(ch)
for item := range ch {
fmt.Println(item.V)
}Output:
1
2
3
Send the Observable items to a given channel that will closed once the operation completes.
ch := make(chan rxgo.Item)
rxgo.Just(1, 2, 3)().Send(ch)
for item := range ch {
fmt.Println(item.V)
}Output:
1
2
3