(t *testing.T)
| 412 | } |
| 413 | |
| 414 | func Test_Just_ComposedCapacity(t *testing.T) { |
| 415 | defer goleak.VerifyNone(t) |
| 416 | obs1 := Just(1)().Map(func(_ context.Context, _ interface{}) (interface{}, error) { |
| 417 | return 1, nil |
| 418 | }, WithBufferedChannel(11)) |
| 419 | assert.Equal(t, 11, cap(obs1.Observe())) |
| 420 | |
| 421 | obs2 := obs1.Map(func(_ context.Context, _ interface{}) (interface{}, error) { |
| 422 | return 1, nil |
| 423 | }, WithBufferedChannel(12)) |
| 424 | assert.Equal(t, 12, cap(obs2.Observe())) |
| 425 | } |
| 426 | |
| 427 | func Test_Merge(t *testing.T) { |
| 428 | defer goleak.VerifyNone(t) |
nothing calls this directly
no test coverage detected
searching dependent graphs…