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 7edafb3 commit 4ac2b87Copy full SHA for 4ac2b87
src/Std/Sync/StreamMap.lean
@@ -60,7 +60,7 @@ Register a new async stream with the given name
60
def register [BEq α] [AsyncStream t β] (sm : StreamMap α β) (name : α) (reader : t) : StreamMap α β :=
61
let newSelector := AsyncStream.next reader
62
let filteredStreams := sm.streams.filter (fun (n, _) => n != name)
63
- { sm with streams := filteredStreams.push (name, newSelector, AsyncStream.stop reader) }
+ { sm with streams := filteredStreams.push (name, newSelector, AsyncStream.stop reader) }
64
65
/--
66
Create a StreamMap from an array of named streams
0 commit comments