Fix spellings (#12277) [backport]
This commit is contained in:
parent
9dd297f613
commit
39290cf88c
110 changed files with 166 additions and 166 deletions
|
|
@ -74,7 +74,7 @@ proc write*[T](future: FutureStream[T], value: T): Future[void] =
|
|||
result.fail(newException(ValueError, msg))
|
||||
return
|
||||
# TODO: Implement limiting of the streams storage to prevent it growing
|
||||
# infinitely when no reads are occuring.
|
||||
# infinitely when no reads are occurring.
|
||||
future.queue.addLast(value)
|
||||
if not future.cb.isNil: future.cb()
|
||||
result.complete()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue