@@ -25,29 +25,6 @@ defmodule StreamTest do
25
25
assert Enum . to_list ( stream ) == [ 3 , 5 , 7 ]
26
26
end
27
27
28
- test "after" do
29
- stream = Stream . after ( [ 1 , 2 , 3 ] , fn -> Process . put ( :stream_after , true ) end )
30
-
31
- # Done
32
- Process . put ( :stream_after , false )
33
- assert Enum . to_list ( stream ) == [ 1 , 2 , 3 ]
34
- assert Process . get ( :stream_after )
35
-
36
- # Halted
37
- Process . put ( :stream_after , false )
38
- assert Enum . take ( stream , 1 ) == [ 1 ]
39
- assert Process . get ( :stream_after )
40
- end
41
-
42
- test "after closes on errors" do
43
- stream = Stream . after ( [ 1 , 2 , 3 ] , fn -> Process . put ( :stream_after , true ) end )
44
-
45
- Process . put ( :stream_after , false )
46
- stream = Stream . map ( stream , fn x -> if x > 2 , do: throw ( :error ) , else: x end )
47
- assert catch_throw ( Enum . to_list ( stream ) ) == :error
48
- assert Process . get ( :stream_after )
49
- end
50
-
51
28
test "chunk" do
52
29
assert Stream . chunk ( [ 1 , 2 , 3 , 4 , 5 ] , 2 ) |> Enum . to_list ==
53
30
[ [ 1 , 2 ] , [ 3 , 4 ] ]
@@ -464,17 +441,14 @@ defmodule StreamTest do
464
441
465
442
test "run" do
466
443
Process . put ( :stream_each , [ ] )
467
- Process . put ( :stream_after , false )
468
444
469
445
stream = [ 1 , 2 , 3 ]
470
- |> Stream . after ( fn -> Process . put ( :stream_after , true ) end )
471
446
|> Stream . each ( fn x ->
472
447
Process . put ( :stream_each , [ x | Process . get ( :stream_each ) ] )
473
448
end )
474
449
475
450
assert is_lazy ( stream )
476
451
assert Stream . run ( stream ) == :ok
477
- assert Process . get ( :stream_after )
478
452
assert Process . get ( :stream_each ) == [ 3 , 2 , 1 ]
479
453
end
480
454
@@ -532,25 +506,6 @@ defmodule StreamTest do
532
506
assert Process . get ( :stream_zip ) == :done
533
507
end
534
508
535
- test "zip/2 closes on inner error" do
536
- stream = Stream . after ( [ 1 , 2 , 3 ] , fn -> Process . put ( :stream_zip , true ) end )
537
- stream = Stream . zip ( stream , Stream . map ( [ :a , :b , :c ] , fn _ -> throw ( :error ) end ) )
538
-
539
- Process . put ( :stream_zip , false )
540
- assert catch_throw ( Enum . to_list ( stream ) ) == :error
541
- assert Process . get ( :stream_zip )
542
- end
543
-
544
- test "zip/2 closes on outer error" do
545
- stream = Stream . after ( [ 1 , 2 , 3 ] , fn -> Process . put ( :stream_zip , true ) end )
546
- |> Stream . zip ( [ :a , :b , :c ] )
547
- |> Stream . map ( fn _ -> throw ( :error ) end )
548
-
549
- Process . put ( :stream_zip , false )
550
- assert catch_throw ( Enum . to_list ( stream ) ) == :error
551
- assert Process . get ( :stream_zip )
552
- end
553
-
554
509
test "with_index" do
555
510
stream = Stream . with_index ( [ 1 , 2 , 3 ] )
556
511
assert is_lazy ( stream )
0 commit comments