We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 22bd1ef commit a1d78ebCopy full SHA for a1d78eb
skip.go
@@ -1,17 +1,5 @@
1
package rx
2
3
-func (observable Observable[T]) aSkip(n int) Observable[T] {
4
- return func(observe Observer[T], scheduler Scheduler, subscriber Subscriber) {
5
- i := 0
6
- observable(func(next T, err error, done bool) {
7
- if done || i >= n {
8
- observe(next, err, done)
9
- }
10
- i++
11
- }, scheduler, subscriber)
12
13
-}
14
-
15
func Skip[T any](n int) Pipe[T] {
16
return func(observable Observable[T]) Observable[T] {
17
return func(observe Observer[T], scheduler Scheduler, subscriber Subscriber) {
0 commit comments