File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 7
7
class Channel { ... }
8
8
9
9
A Channel is a thread-safe queue that helps you to send a series of objects from
10
- potentially mutltiple produces to potentially multiple consumers.
10
+ one or more producers to one or more consumers.
11
11
12
12
my $c = Channel.new;
13
13
await (^10).map: {
@@ -26,15 +26,15 @@ potentially mutltiple produces to potentially multiple consumers.
26
26
27
27
method send(Channel:D: \item)
28
28
29
- Enqueues an into the channel. Throws an exception of type
29
+ Enqueues an item into the channel. Throws an exception of type
30
30
C < X::Channel::SendOnClosed > if the channel has been closed already.
31
31
32
32
= head2 method receive
33
33
34
34
method receive(Channel:D:)
35
35
36
36
Receives and removes an item from the channel. It blocks if no item is
37
- present, waiting for a C < . send> from another thread.
37
+ present, waiting for a C < send > from another thread.
38
38
39
39
Throws an exception of
40
40
type C < X::Channel::ReceiveOnClose > if the channel has been closed, and the
@@ -69,7 +69,7 @@ and is a prerequisite for C<list> to terminate.
69
69
method list(Channel:D:) returns List:D
70
70
71
71
Returns a list of all remaining items in the queue, and removes them from the
72
- channel. This can only terminate once C < . close> has been called.
72
+ channel. This can only terminate once C < close > has been called.
73
73
74
74
= head2 method closed
75
75
You can’t perform that action at this time.
0 commit comments