@@ -539,28 +539,28 @@ reached:
539
539
540
540
=back
541
541
542
- There are some combinators that deal with bringing multiple subscribables
542
+ There are some combinators that deal with bringing multiple supplies
543
543
together:
544
544
545
545
=over
546
546
547
547
=item C<merge>
548
548
549
- produces a subscribable containing the values produced by two
550
- other subscribables , and triggering C<done> once both of the subscribables have
549
+ produces a supply containing the values produced by two
550
+ other supplies , and triggering C<done> once both of the supplies have
551
551
done so.
552
552
553
553
=item C<zip>
554
554
555
- produces a subscribable that pairs together items from two other
556
- subscribables , using C<< infix:<,> >> by default or any other user-supplied
555
+ produces a supply that pairs together items from two other
556
+ supplies , using C<< infix:<,> >> by default or any other user-supplied
557
557
function.
558
558
559
559
=back
560
560
561
561
[TODO: plenty more of these: combine_latest, while, until...]
562
562
563
- These combinators that involve multiple subscribables need care in their
563
+ These combinators that involve multiple supplies need care in their
564
564
implementation, since values may arrive at any point on each, and possibly at
565
565
the same time. To help write such combinators, the C<on> meta-combinator is
566
566
useful. C<on> taps many supplies, and ensures that only one
@@ -588,8 +588,8 @@ about synchronization issues. Here is how C<zip> is implemented:
588
588
589
589
Thus there is never any race or other thread-safely problems with mutating the
590
590
C<@as> and C<@bs>. The default behaviour, if a callable is specified along
591
- with the subscribable , is to use it for C<more> and provide a default C<done>
592
- and C<fail>. The default C<done> triggers C<done> on the result subscribable ,
591
+ with the supply , is to use it for C<more> and provide a default C<done>
592
+ and C<fail>. The default C<done> triggers C<done> on the result supply ,
593
593
which is the correct semantics for C<zip>. On the other hand, C<merge> wants
594
594
different semantics, and so must provide a C<done>. This is done as follows:
595
595
@@ -612,7 +612,7 @@ different semantics, and so must provide a C<done>. This is done as follows:
612
612
}
613
613
614
614
A C<fail> can be provided in a similar way, although the default - convey the
615
- failure to the result subscribable - is normally what is wanted. The exception
615
+ failure to the result supply - is normally what is wanted. The exception
616
616
is writing combinators related to error handling.
617
617
618
618
[TODO: specify C<catch> and various other error-handling related timeouts.]
0 commit comments