1 parent 9b35d4d commit 826fe2dCopy full SHA for 826fe2d
1 file changed
lib/emily/stream.ex
@@ -86,8 +86,7 @@ defmodule Emily.Stream do
86
"""
87
@spec with_stream(t(), (-> result)) :: result when result: var
88
def with_stream(%__MODULE__{worker: w}, fun) when is_function(fun, 0) do
89
- prev = Process.get(:emily_worker)
90
- Process.put(:emily_worker, w)
+ prev = Process.put(:emily_worker, w)
91
92
try do
93
fun.()
0 commit comments