diff --git a/spec.bs b/spec.bs index a82b81c..5a739db 100644 --- a/spec.bs +++ b/spec.bs @@ -770,8 +770,9 @@ For now, see [https://github.com/wicg/observable#operators](https://github.com/w 1. Let |observable| be a [=new=] {{Observable}} whose [=Observable/subscribe callback=] is an algorithm that takes a {{Subscriber}} |subscriber| and does the following: + 1. Let |remaining| be |amount|. - 1. If |amount| is 0, then run |subscriber|'s {{Subscriber/complete()}} method and abort + 1. If |remaining| is 0, then run |subscriber|'s {{Subscriber/complete()}} method and abort these steps. 1. Let |sourceObserver| be a new [=internal observer=], initialized as follows: @@ -780,9 +781,9 @@ For now, see [https://github.com/wicg/observable#operators](https://github.com/w :: 1. Run |subscriber|'s {{Subscriber/next()}} method with the passed in value. - 1. Decrement |amount|. + 1. Decrement |remaining|. - 1. If |amount| is 0, then run |subscriber|'s {{Subscriber/complete()}} method. + 1. If |remaining| is 0, then run |subscriber|'s {{Subscriber/complete()}} method. : [=internal observer/error steps=] :: Run |subscriber|'s {{Subscriber/error()}} method, given the passed in value.