Skip to content

Commit d95e6f6

Browse files
committed
doc(examples): add missing examples in ro_example_test.go
1 parent 95afa53 commit d95e6f6

File tree

3 files changed

+1004
-241
lines changed

3 files changed

+1004
-241
lines changed

operator_combining.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -587,7 +587,7 @@ func CombineLatestWith4[A, B, C, D, E any](obsB Observable[B], obsC Observable[C
587587
var status int32
588588

589589
onUpdate := func(ctx context.Context, a *A, b *B, c *C, d *D, e *E) {
590-
if atomic.LoadInt32(&status) < 4 {
590+
if atomic.LoadInt32(&status) < 5 {
591591
if a == nil {
592592
a = valueA.Load()
593593
}

operator_transformations_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,19 +90,19 @@ func TestOperatorTransformationMapTo(t *testing.T) {
9090
is := assert.New(t)
9191

9292
values, err := Collect(
93-
MapTo[int, int](42)(Just(1, 2, 3)),
93+
MapTo[int](42)(Just(1, 2, 3)),
9494
)
9595
is.Equal([]int{42, 42, 42}, values)
9696
is.NoError(err)
9797

9898
values, err = Collect(
99-
MapTo[int, int](42)(Empty[int]()),
99+
MapTo[int](42)(Empty[int]()),
100100
)
101101
is.Equal([]int{}, values)
102102
is.NoError(err)
103103

104104
values, err = Collect(
105-
MapTo[int, int](42)(Throw[int](assert.AnError)),
105+
MapTo[int](42)(Throw[int](assert.AnError)),
106106
)
107107
is.Equal([]int{}, values)
108108
is.EqualError(err, assert.AnError.Error())

0 commit comments

Comments
 (0)