@@ -424,17 +424,19 @@ are emitted, but with the given delay in seconds.
424
424
425
425
= head2 method throttle
426
426
427
- = for code :skip-test<compile time error>
428
- method throttle(Supply:D:
429
- $limit, # values / time or simultaneous processing
430
- $seconds or $callable, # time-unit / code to process simultaneously
431
- $delay = 0, # initial delay before starting, in seconds
432
- :$control, # supply to emit control messages on (optional)
433
- :$status, # supply to tap status messages from (optional)
434
- :$bleed, # supply to bleed messages to (optional)
435
- :$vent-at, # bleed when so many buffered (optional)
436
- :$scheduler, # scheduler to use, default $*SCHEDULER
437
- --> Supply:D)
427
+
428
+
429
+ = begin table
430
+ Argument | Meaning
431
+ ========================================================================
432
+ $limit, | values / time or simultaneous processing
433
+ $seconds or $callable, | time-unit / code to process simultaneously
434
+ $delay = 0, | initial delay before starting, in seconds
435
+ :$control, | supply to emit control messages on (optional)
436
+ :$status, | supply to tap status messages from (optional)
437
+ :$bleed, | supply to bleed messages to (optional)
438
+ :$vent-at, | bleed when so many buffered (optional)
439
+ :$scheduler, | scheduler to use, default $*SCHEDULER
438
440
439
441
Produces a C < Supply > from a given Supply, but makes sure the number of
440
442
messages passed through is limited.
0 commit comments